THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
package org.apache.kafka.streams.processor;
TaskMetadata.java
public Map<TopicPartition, Long> committedOffsets();
public Map<TopicPartition, Long> endOffsets();
public Long timeCurrentIdlingStarted(); |
...