THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| 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> endOffsets(); /** * This function will return the time task idling started, if the task is not currently idling it will return -1 */ public LongOptional<Long> timeCurrentIdlingStarted(); |
...
This will record the time the task started idling. Once the task has stopped idling it will reset to -1return empty. This also lets the user verify if the task is idling properly as they can compare the time with the config for the max idling time.
...