Ewen Cheslack-Postava created KAFKA-4403:
--------------------------------------------
Summary: Update KafkaBasedLog to use new endOffsets consumer API
Key: KAFKA-4403
URL: https://issues.apache.org/jira/browse/KAFKA-4403
Project: Kafka
Issue Type: Bug
Components: KafkaConnect
Affects Versions: 0.10.1.0
Reporter: Ewen Cheslack-Postava
Assignee: Ewen Cheslack-Postava
Priority: Minor
As of 0.10.1.0 and KIP-79
(https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65868090)
KafkaConsumer can now fetch offset information about topic partitions.
Previously KafkaBasedLog had to use a seekToEnd + position approach to
determine end offsets. With the new APIs we can simplify this code.
This isn't critical as the current code works fine, but would be a nice cleanup
and simplification.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
