zhengkw opened a new pull request #344:
URL: https://github.com/apache/flume/pull/344
When I use the Multiplexing Channel Selector in apache-flume-ng-1.9.0, I
found that the topicHeader parameter specified in KafkaSource does not work
properly for mapping. Refer to the source code of kafkasource and found that in
line 266, the key of the map that put into the header is a dynamic parameter,
but in my humbly opinion , this should be a static string ("topicHeader").
after I modify the source code, the selector works normally !
--
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
