Page History

package org.apache.kafka.streams;
  
KafkaStreams.java
/**
* Returns the last committed offset for each task.
*/
public Map<TaskIdMap<TopicPartition, Integer> committedOffsets();

/**
* Returns if a task is idling.
*
* @param taskId the id for the task that is being checked.
*/
public boolean isTaskIdling(TaskId taskId)