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)
