GitHub user hmcl opened a pull request:
https://github.com/apache/storm/pull/2465
STORM-2844: KafkaSpout Throws IllegalStateException After Committing to
Kafka When First Poll Strategy Set to EARLIEST
- Serialize KafkaSpoutMessageId to JSON and add it as part of
OffsetAndMetadata
- Check if commits to Kafka were committed by this topology to correctly
enforce FirstPollOffsetStrategy
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hmcl/storm-apache
1.x-branch_STORM-2844_ISEEarliest
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/2465.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 #2465
----
commit 0b3f294129e83908d5a8fdc2030937f915af044d
Author: Hugo Louro <[email protected]>
Date: 2017-12-15T23:05:50Z
STORM-2844: KafkaSpout Throws IllegalStateException After Committing to
Kafka When First Poll Strategy Set to EARLIEST
- Serialize KafkaSpoutMessageId to JSON and add it as part of
OffsetAndMetadata
- Check if commits to Kafka were committed by this topology to correctly
enforce FirstPollOffsetStrategy
----
---
