You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flume.apache.org by GitBox <gi...@apache.org> on 2022/03/14 07:26:43 UTC

[GitHub] [flume] tmgstevens commented on pull request #346: Resolved that when using KafkaChannel, Kafka-related metadata information could not be obtained in sink

tmgstevens commented on pull request #346:
URL: https://github.com/apache/flume/pull/346#issuecomment-1066460538


   There is definitely a risk that this will change behaviour, particularly if used by a KafkaSink. I think we need to make this behaviour turned off by default and also allow the user to customise the name of the headers that she wishes to use for each field. We've got some fairly good examples of that sort of pattern here: https://github.com/apache/flume/blob/trunk/flume-ng-sources/flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java#L264


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: dev-unsubscribe@flume.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org