Page History

package org.apache.kafka.streams;
  
KafkaStreams.java
/**
* Returns the last committed offset for each TopicPartition in a task assigned to this client.
*/
public Map<TopicPartition, Long> committedOffsets();

/**
* Returns a map telling if each task is idling.
*
*/
public Map<TaskId, boolean> tasksIdling()