[jira] [Commented] (FLUME-2874) A new interceptor called Key Interceptor should be created to insert a header with key "key" which will be used in Kakfa Sink

[ https://issues.apache.org/jira/browse/FLUME-2874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15211379#comment-15211379 ] Li Ye commented on FLUME-2874: -- Thanks for your watching. I have closed this JIRA. Please wat

[jira] [Commented] (FLUME-2874) A new interceptor called Key Interceptor should be created to insert a header with key "key" which will be used in Kakfa Sink

[ https://issues.apache.org/jira/browse/FLUME-2874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15211375#comment-15211375 ] Li Ye commented on FLUME-2874: -- Yes > A new interceptor called Key Interceptor should be cre

[jira] [Commented] (FLUME-2874) A new interceptor called Key Interceptor should be created to insert a header with key "key" which will be used in Kakfa Sink

[ https://issues.apache.org/jira/browse/FLUME-2874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15211370#comment-15211370 ] Ambud Sharma commented on FLUME-2874: - [~l90006322] can we mark this as resolved? > A

[jira] [Commented] (FLUME-2874) A new interceptor called Key Interceptor should be created to insert a header with key "key" which will be used in Kakfa Sink

[ https://issues.apache.org/jira/browse/FLUME-2874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15211347#comment-15211347 ] Jeff Holoman commented on FLUME-2874: - FLUME-2820 takes care of this. If there is a ke

[jira] [Commented] (FLUME-2874) A new interceptor called Key Interceptor should be created to insert a header with key "key" which will be used in Kakfa Sink

[ https://issues.apache.org/jira/browse/FLUME-2874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15209874#comment-15209874 ] Ambud Sharma commented on FLUME-2874: - Can you leverage the Morphline interceptor htt

[jira] [Commented] (FLUME-2874) A new interceptor called Key Interceptor should be created to insert a header with key "key" which will be used in Kakfa Sink

[ https://issues.apache.org/jira/browse/FLUME-2874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15209855#comment-15209855 ] Li Ye commented on FLUME-2874: -- Please watch my another JIRA https://issues.apache.org/jira/b

[jira] [Commented] (FLUME-2874) A new interceptor called Key Interceptor should be created to insert a header with key "key" which will be used in Kakfa Sink

[ https://issues.apache.org/jira/browse/FLUME-2874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15209846#comment-15209846 ] Ambud Sharma commented on FLUME-2874: - This would require changing the Kafka Sink and