Kafka Configs Kafka Protocol Wire Format API Versions KIPs Errors Exceptions Kafka Upgrade Config Advisor Policy Pack
Debezium
Config Matrix Event Envelope Snapshot Modes Error Reference
Flink SQL
conduktor.io ↗
KIPs / KIP-845

KIP-845 — 'HasField' predicate for kafka connect

Discarded Connect

Adds a `HasField` predicate to Kafka Connect's Single Message Transforms (SMTs) that checks whether a record key or value contains a specified field. This allows transforms like `TimestampConverter` to be conditionally applied only when a field exists, avoiding exceptions from transforms that fail on missing fields.

Details

AuthorKumud Kumar Srivatsava Tirupati
StatusDiscarded
JIRAKAFKA-13926
WikiView on Apache Wiki
Created2022-05-24
Last Modified2022-06-04
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.