streamthoughts/azkarra-streams

MonitoringStreamsInterceptor should report local state stores offset lags

fhussonnois opened this issue · 0 comments

fhussonnois commented

Kafka Streams 2.5 introduces the API KafkaStreams#allLocalStorePartitionLags. The MonitoringStreamsInterceptor should optionnally reports the partitions lags for all local state stores.

This issue should added a new interceptor config : monitoring.streams.interceptor.info.enabled.stores.lag