...

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 TaskMetadata that report the progress Kafka exposes already. Any health check service will just need to query all clients and aggregate their responses to get a complete picture of all tasks.

Public Interfaces

package org.apache.kafka.streams.processor;
TaskMetadata.java

public Map<TopicPartition, Long> committedOffsets();
public Map<TopicPartition, Long> endOffsets();
public Long timeCurrentIdlingStarted();

...