[jira] [Commented] (FLUME-3046) Kafka Sink and Source Configuration Improvements

["Tristan Stevens (JIRA)" <ji...@apache.org>]

    [ 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)