[GitHub] [flume] zhengkw opened a new pull request #344: fixed the key of map in 266 line

[GitBox <gi...@apache.org>]

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:
users@infra.apache.org

[GitHub] [flume] zhengkw closed pull request #344: fixed the key of map in 266 line

[GitBox <gi...@apache.org>]

zhengkw closed pull request #344:
URL: https://github.com/apache/flume/pull/344


   


-- 
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:
users@infra.apache.org