Jeremy Custenborder created KAFKA-7273: ------------------------------------------
Summary: Converters should have access to headers. Key: KAFKA-7273 URL: https://issues.apache.org/jira/browse/KAFKA-7273 Project: Kafka Issue Type: Improvement Components: KafkaConnect Reporter: Jeremy Custenborder I found myself wanting to build a converter that stored additional type information within headers. The converter interface does not allow a developer to access to the headers in a Converter. I'm not suggesting that we change the method for serializing them, rather that *org.apache.kafka.connect.header.Headers* be passed in for *fromConnectData* and *toConnectData*. For example something like this. {code:java} import org.apache.kafka.connect.data.Schema; import org.apache.kafka.connect.data.SchemaAndValue; import org.apache.kafka.connect.header.Headers; import org.apache.kafka.connect.storage.Converter; public interface ExtendedConverter extends Converter { byte[] fromConnectData(String topic, Headers headers, Schema schema, Object object); SchemaAndValue toConnectData(String topic, Headers headers, byte[] payload); } {code} This would be a similar approach to what was already done with ExtendedDeserializer and ExtendedSerializer in the Kafka client. -- This message was sent by Atlassian JIRA (v7.6.3#76005)