kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams
Date Thu, 01 Sep 2016 18:53:21 GMT
Matthias J. Sax created KAFKA-4114:

             Summary: Allow for different "auto.offset.reset" strategies for different input
                 Key: KAFKA-4114
                 URL: https://issues.apache.org/jira/browse/KAFKA-4114
             Project: Kafka
          Issue Type: Sub-task
          Components: streams
            Reporter: Matthias J. Sax
            Assignee: Guozhang Wang

Today we only have one consumer config "offset.auto.reset" to control that behavior, which
means all streams are read either from "earliest" or "latest".

However, it would be useful to improve this settings to allow users have finer control over
different input stream. For example, with two input streams, one of them always reading from
offset 0 upon (re)-starting, and the other reading for log end offset.

This JIRA requires to extend {{KStreamBuilder}} API for methods {{.stream(...)}} and {{.table(...)}}
to add a new parameter that indicate the initial offset to be used.

This message was sent by Atlassian JIRA

View raw message