bitsail icon indicating copy to clipboard operation
bitsail copied to clipboard

[BitSail][Connector] Support more send method in Kafka writer.

Open BlockLiu opened this issue 3 years ago • 2 comments

Is your feature request related to a problem? Please describe

Current KafkaOutputFormat supports only the following two send method in KafkaProducer:

  • public Future<RecordMetadata> send(ProducerRecord<K, V> record, Callback callback)
  • public Future<RecordMetadata> send(ProducerRecord<K, V> record, Callback callback)

Sometimes, one may want to add more data in the ProducerRecord such as key or header. So this issue wants to extend current KafkaOutputFormat to support more send method.

Describe the solution you'd like

Describe alternatives you've considered

Additional context

BlockLiu avatar Nov 09 '22 03:11 BlockLiu

hi @BlockLiu I'd like to have a try, please assign it to me.

zeliu avatar Nov 10 '22 11:11 zeliu

Sure, take your time!

BlockLiu avatar Nov 10 '22 11:11 BlockLiu