You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by tmgstevens <gi...@git.apache.org> on 2017/01/23 21:30:33 UTC
[GitHub] flume pull request #105: Flume 3046 - Kafak Sink and Source Configuration Im...
GitHub user tmgstevens opened a pull request:
https://github.com/apache/flume/pull/105
Flume 3046 - Kafak Sink and Source Configuration Improvements
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.
Adds configuration to Kafka Source to either disable the "topic" header, or at least configure it, and the same for the Kafka Sink,
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tmgstevens/flume FLUME-3046
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flume/pull/105.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #105
----
commit d849f5ab2db104e21d87795822d6d90bfedd3509
Author: Tristan Stevens <tr...@cloudera.com>
Date: 2016-04-05T08:33:43Z
Merge remote-tracking branch 'apache/trunk' into trunk
commit 4c76b1709e92983c0b8b0c87a52363f78b75e1fa
Author: Tristan Stevens <tr...@cloudera.com>
Date: 2016-04-25T15:46:10Z
Merge remote-tracking branch 'apache/trunk' into trunk
commit 1bb7b9acda688beecff83fd6a41ced083ba4506f
Author: Tristan Stevens <tr...@cloudera.com>
Date: 2017-01-23T21:19:35Z
Merge remote-tracking branch 'apache/trunk' into trunk
commit 2ae3662cc1d6e841c5fc6a5819e5f6cd6aed3193
Author: Tristan Stevens <tr...@cloudera.com>
Date: 2017-01-23T21:24:33Z
Changes for FLUME-3046 to introduce configuration to Kafka Source and Kafka Sink to avoid loopback effect due to 'topic' headers.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flume pull request #105: FLUME-3046: Kafka Sink and Source Configuration Imp...
Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:
https://github.com/apache/flume/pull/105
---