Pulsar IO: KafkaSink handle KeyValue schema

apache / pulsar

Apache Pulsar - distributed pub-sub messaging system

https://pulsar.apache.org/

Apache License 2.0

14.23k stars 3.58k forks source link

Open eolivelli opened 2 years ago

eolivelli commented 2 years ago

Is your enhancement request related to a problem? Please describe. KafkaSink does not work with KeyValue schema.

Describe the solution you'd like KafkaSink should work with KeyValue schema, I am especially interested in the case of KeyValue<AVRO,AVRO>

Describe alternatives you've considered Use function to convert from KeyValue to something else

github-actions[bot] commented 2 years ago

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