GitHub user hmcl opened a pull request:
https://github.com/apache/storm/pull/2466
STORM-2844: KafkaSpout Throws IllegalStateException After Committing â¦
â¦to Kafka When First Poll Strategy Set to EARLIEST
- Check if commits to Kafka were committed by this topology to
correctly enforce FirstPollOffsetStrategy
- CommitMetadata includes topology id, and task id and threadName
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hmcl/storm-apache
Apache_master_STORM-2844_ISEEarliest
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/2466.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 #2466
----
commit 41eaf0d1bb3e8e9d57cac4349c4338d4d2b61ebf
Author: Hugo Louro <hmclo...@gmail.com>
Date: 2017-12-18T03:59:38Z
STORM-2844: KafkaSpout Throws IllegalStateException After Committing to
Kafka When First Poll Strategy Set to EARLIEST
- Check if commits to Kafka were committed by this topology to
correctly enforce FirstPollOffsetStrategy
- CommitMetadata includes topology id, and task id and threadName
----
---
