Kafka Sink Connector: support non-String keys

Open eolivelli opened this issue 4 years ago • 3 comments

Currently the Kafka Sink Connector is able to support only keys with a String value.

We should support the generic byte[] key, as it is in Kafka. Also we should support other data types and possibly may the generic key/value pair of Kafka to a KeyValue Pulsar schema

Mar 09 '21 07:03 eolivelli

@sijie comment in #9448

we need to make the key as pure bytes because that's the default behavior from Kafka.

KafkaAbstractSource -> KafkaAbstractStringKeySource -> KafkaStringSource KafkaAbstractSource -> KafkaAbstractBytesKeySource -> KafkaBytesSource

Mar 09 '21 07:03 eolivelli

The issue had no activity for 30 days, mark with Stale label.

Mar 04 '22 07:03 codelipenghui

It seems that the latest version has already supported the generic byte[] key, should this issue be closed?

Jul 17 '24 08:07 pcyan