Details
-
Bug
-
Status: Resolved
-
Critical
-
Resolution: Fixed
-
1.x
-
None
Description
With UNCOMMITED_LATEST offset, Storm-Kafka-Client Trident Spout doesn't read all the data.
See worker logs for of the same topology with UNCOMMITED_EARLIEST as well as UNCOMITTED_LATEST.
The source topic has 3 partition and I publish data k000000-k000499(k000000, v000000 etc.)
In particular for k000000 value the data is not picked by spout at all.
Attachments
Attachments
Issue Links
- links to