vvcephei commented on a change in pull request #10137:
URL: https://github.com/apache/kafka/pull/10137#discussion_r577333186
##########
File path: clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java
##########
@@ -243,6 +244,11 @@
*/
Map<TopicPartition, Long> endOffsets(Collection<TopicPartition>
partitions, Duration timeout);
+ /**
+ * @see KafkaConsumer#currentLag(TopicPartition)
+ */
+ OptionalLong currentLag(TopicPartition topicPartition);
Review comment:
Woah, you are _fast_, @chia7712 !
I just sent a message to the vote thread. I wanted to submit this PR first
so that the vote thread message can have the full context available.
Do you mind reading over what I said there? If it sounds good to you, then
I'll update the KIP, and we can maybe put this whole mess to bed.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
