GitHub user bbejeck opened a pull request:
https://github.com/apache/kafka/pull/2007
Kafka 4114 allow different offset reset strategies
@mjsax
Here's my first pass at finer grained auto offset reset strategies.
I've left TODO comments about whether we want to consider adding this to
`KGroupedTable.aggregate` and `KStreamImpl` when re-partitioning a source.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bbejeck/kafka
KAFKA-4114_allow_different_offset_reset_strategies
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/2007.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 #2007
----
commit 7f96f19894c617c6f4568202511431ad2a1551f3
Author: bbejeck <[email protected]>
Date: 2016-10-06T01:40:13Z
KAFKA-4114 : initial work on different auto offset reset strategies for
different input streams
commit eec398a960b89840dca7e3d24bc563de5a96faa1
Author: bbejeck <[email protected]>
Date: 2016-10-08T01:45:09Z
KAFKA-4114 : added additional overloaded methods to TopologyBuilder,
cleaned up test, reverted KGroupedTableImpl, KStreamImpl and
ProcessorTopologyTest to orignal state with new overloaded methods
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
