You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by bbejeck <gi...@git.apache.org> on 2016/10/11 00:52:33 UTC

[GitHub] kafka pull request #2007: Kafka 4114 allow different offset reset strategies

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 <bb...@gmail.com>
Date:   2016-10-06T01:40:13Z

    KAFKA-4114 : initial work on different auto offset reset strategies for different input streams

commit eec398a960b89840dca7e3d24bc563de5a96faa1
Author: bbejeck <bb...@gmail.com>
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] kafka pull request #2007: KAFKA-4114: allow different offset reset strategie...

Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:

    https://github.com/apache/kafka/pull/2007


---
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---