Kafka Connect DropHeaders SMT Usage Reference for Confluent Cloud

The following provides usage information for the Apache Kafka® SMT org.apache.kafka.connect.transforms.DropHeaders.

Description

Drops one or more headers from each record.

Example

This configuration snippet shows how to use DropHeaders to drop the headers named app.id and txn.id.

"transforms": "dropAppIdHeader",
"transforms.dropAppIdHeader.type": "org.apache.kafka.connect.transforms.DropHeaders",
"transforms.dropAppIdHeader.headers": "app.id,txn.id"

Before: Headers app.id and txn.id included in records.

After: Headers app.id and txn.id dropped from records.

Properties

Name	Description	Type		Valid Values	Importance
headers	One or more (comma-separated) header names to drop.	string		non-empty list	medium

Predicates

Transformations can be configured with predicates so that the transformation is applied only to records which satisfy a condition. You can use predicates in a transformation chain and, when combined with the Kafka Connect Filter (Kafka) SMT Usage Reference for Confluent Cloud, predicates can conditionally filter out specific records. For details and examples, see Predicates.