[ https://issues.apache.org/jira/browse/FLUME-3046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066300#comment-16066300 ]
Tristan Stevens commented on FLUME-3046: ---------------------------------------- [~jholoman] [~denes] This PR has been open for a while and is actually quite a big issue (infinite loops when using Kakfa Sources with Kafka Sinks). Could we get a re-review and commit please (I've rebased on trunk and merged in FLUME-3100). > Kafka Sink and Source Configuration Improvements > ------------------------------------------------ > > Key: FLUME-3046 > URL: https://issues.apache.org/jira/browse/FLUME-3046 > Project: Flume > Issue Type: Bug > Affects Versions: 1.7.0 > Reporter: Jeff Holoman > Assignee: Tristan Stevens > > Currently the Kafka Source sets the header for the topic. The sink reads this > value, rather than the statically defined topic value. We should fix this so > that you can either change the topic header that is used, or just choose to > prefer the statically defined topic in the sink. -- This message was sent by Atlassian JIRA (v6.4.14#64029)