THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
This new feature require to add a new method to StreamTask in order to retrieved retrieve last consumed offsets.
Code Block | ||
---|---|---|
| ||
/** * @return latest consumed offsets by partition */ public Map<TopicPartition, Long> consumedOffsets() { return Collections.unmodifiableMap(this.consumedOffsets); } |
A straightforward first pass is GitHub PR 2612
Compatibility, Deprecation, and Migration Plan
...