...
This page is meant as a template for writing a KIP. To create a KIP choose Tools->Copy on this page and modify with your content and replace the heading with the next KIP number and a description of your issue. Replace anything in italics with your own description.
Status
Current state: "Under DiscussionAccepted"
Discussion thread: here [Change the link from the KIP proposal email archive to your own email thread]
...
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
package org.apache.kafka.streams.processor; /** * This function will return a map of TopicPartitions and the highest committed offset seen so far */ public Map<TopicPartition, Long> committedOffsets(); /** * This function will return a map of TopicPartitions and the highest offset seen so far */ public Map<TopicPartition, Long> highWatermarksendOffsets(); /** * This function will return the time task idling started, if the task is not currently idling it will return -1empty */ public Optional<Long> timeCurrentIdlingStarted(); |
...
This method will return a map that contains a mapping of all TopicPartitions and their committed offsets. The committed offset will be the highest seen so far.
...
endOffsets
Similarly this method will return a map that contains a mapping of all TopicPartitions and their high watermark offset.
...