...

If you are a Kafka user and you want to track the progress a client is making you can use the returned committed offset. However Streams does not have that capability as several Kafka clients are embedded in Streams client. This KIP proposes to add methods to Kafka Streams that repost report the progress Kafka exposes already.

...

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

/**
* Returns a map telling if aeach task is idling.
*
* @param taskId the id for the task that is being checked.
*/
public Map<TaskId, booleanboolean> isTaskIdlingtasksIdling(TaskId taskId)

Proposed Changes

committedOffsets

This should have the latest committed off set of each task assigned to the client. Each poll will update this.

...