Github user roshannaik commented on the issue:
https://github.com/apache/storm/pull/2241
@revans2. Thanks, I have fixed that issue in the latest commit. Also added
a perf tuning document
GitHub user bijanfahimi opened a pull request:
https://github.com/apache/storm/pull/2282
STORM-2694: Add KafkaTupleListener to storm-kafka-client
This PR proposes an improvement to the KafkaSpout. A KafkaTupleListener
interface can now be implemented to handle state changes of the
Github user revans2 commented on the issue:
https://github.com/apache/storm/pull/2241
@roshannaik I found another bug in the code. For batching you are deciding
to turn on or off flushing based off of the system conf, and not the topology
conf. This means that I as a topology owner
