You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/25 20:36:11 UTC
[jira] [Commented] (STORM-1352) Trident should support writing to
multiple Kafka clusters
[ https://issues.apache.org/jira/browse/STORM-1352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15027436#comment-15027436 ]
ASF GitHub Bot commented on STORM-1352:
---------------------------------------
GitHub user haohui opened a pull request:
https://github.com/apache/storm/pull/905
STORM-1352. Trident should support writing to multiple Kafka clusters.
This PR allows users to specify multiple Kafka configurations so that the topology can write to multiple Kafka clusters.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/haohui/storm STORM-1352
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/905.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 #905
----
commit 2f6b9daf4e4ef1814db5bd83859e92275ced808e
Author: Haohui Mai <wh...@apache.org>
Date: 2015-11-25T19:30:22Z
STORM-1352. Trident should support writing to multiple Kafka clusters.
----
> Trident should support writing to multiple Kafka clusters
> ---------------------------------------------------------
>
> Key: STORM-1352
> URL: https://issues.apache.org/jira/browse/STORM-1352
> Project: Apache Storm
> Issue Type: Improvement
> Reporter: Haohui Mai
> Assignee: Haohui Mai
>
> Current it is impossible to instantiate two instances of the {{TridentKafkaState}} class that write to different Kafka cluster. This is because that {{TridentKafkaState}} obtains the the location of the Kafka producer from configuration. Multiple instances can only get the same configuration in the {{prepare()}} method.
> This jira proposes to introduce a configuration class like {{TridentKafkaConfig}} to allow multiple instances of {{TridentKafkaState}} to write to different Kafka clusters.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)