[jira] [Updated] (TWILL-199) Get next offset and handle offset error in KafkaConsumer.MessageCallback

["Terence Yim (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/TWILL-199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Terence Yim updated TWILL-199:
------------------------------
    Fix Version/s: 0.10.0

> Get next offset and handle offset error in KafkaConsumer.MessageCallback
> ------------------------------------------------------------------------
>
>                 Key: TWILL-199
>                 URL: https://issues.apache.org/jira/browse/TWILL-199
>             Project: Apache Twill
>          Issue Type: Improvement
>            Reporter: Chengfeng Mao
>            Assignee: Chengfeng Mao
>             Fix For: 0.10.0
>
>
> The method {{void onReceived(Iterator<FetchedMessage> messages)}} in {{KafkaConsumer.MessageCallback}} can be more flexible with the change to {{Long onReceived(Iterator<FetchedMessage> messages)}} so that it can provide additional functionalities:
> 1. To return the next offset to be fetched
> 2. To handle offset non-existence or offset mismatch error and take action on the error
> This method will return null for backward compatibility when it doesn't need to provide the next offset.
> In concrete implementation,  a class of a new interface {{KafkaOffsetProvider}} can be added as a member in {{KafkaConsumer.MessageCallback}} to perform the offset error handling and provide the next offset. Besides, {{KafkaOffsetProvider}} also has methods to provide the following functionalities:
> 1. To fetch earliest/latest offset in Kafka
> 2. To find the offset of a message with timestamp equal to the given timestamp in Kafka
> For backward compatibility, if {{KafkaOffsetProvider}} instance is not provided, its default value will be null and none of its methods will be called.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)