logging-flume icon indicating copy to clipboard operation
logging-flume copied to clipboard

FLUME-3327 add useKafkaHeader option to convert flume headers as kafk…

Open stakafum opened this issue 6 years ago • 5 comments

…a ones transparently in KafkaSource,

KafkaChannel, and KafkaSink

stakafum avatar Apr 03 '19 10:04 stakafum

+1 for this feature ^^

slem1 avatar Sep 03 '19 13:09 slem1

Is there a chance for it to get in if all the comments are addressed?

kamazee avatar Sep 03 '20 16:09 kamazee

Is there a chance for it to get in if all the comments are addressed?

I don't have the time and resources to do a proper review here, but when the comments are addressed and @tmgstevens approves the change, then I don't see why not.

bessbd avatar Sep 07 '20 16:09 bessbd

Yes, I'm happy to push this once the comments have been resolved.

tmgstevens avatar Sep 08 '20 10:09 tmgstevens

This has conflicts with the patch I just applied for FLUME-3435 which adds support for the timestamp and headers to KafkaSink and KafkaSource. I did not add them to KafkaChannel as I wasn't sure if the semantics should be the same.

rgoers avatar Oct 08 '22 04:10 rgoers