Github user aniketalhat closed the pull request at:
https://github.com/apache/storm/pull/2755
---
Github user aniketalhat commented on a diff in the pull request:
https://github.com/apache/storm/pull/2755#discussion_r200866147
--- Diff:
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/NamedTopicFilter.java
---
@@ -54,8 +57,12 @@ public NamedTopicFilter
Github user aniketalhat commented on a diff in the pull request:
https://github.com/apache/storm/pull/2755#discussion_r200802071
--- Diff:
external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicPartitionConnections.java
---
@@ -57,6 +57,7 @@ public SimpleConsumer register
Github user aniketalhat commented on the issue:
https://github.com/apache/storm/pull/2755
@srdo I checked out my branch from master, I changed the target and we have
conflicts, obviously. Do you recommend checking out from 1.x ?
---
GitHub user aniketalhat opened a pull request:
https://github.com/apache/storm/pull/2755
[WIP] STORM-3082 Add support to handle absent topics
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aniketalhat/storm
feature/STORM-3082
Github user aniketalhat commented on the issue:
https://github.com/apache/storm/pull/2066
Hello Liu,
Thanks for your quick reply, my one concern is that your PR is for
storm-kafka-client(new consumer) where as I'm looking for storm-kafka(old
consumer) solution, wh
Github user aniketalhat commented on the issue:
https://github.com/apache/storm/pull/2066
@liu-zhaokun how did you manage to solve this? Currently new
storm-kafka-client isn't very stable and doesn't support the transactional
spout. I've to connect to Kafka (0.11.0.2
