Adding kafka consumer group for reporting offset back to Kafka

[xiangfu0]

Requirements: have a way to track/compare the physical Kafka ingestion lag.

This can be an optional stream config to report the consumer lag periodically to Kafka for tracking purpose.

It's not for any data flow management like offset reset kind of usage.

[vivekkoya]

Hello, I would like to take this task. How can I get started? Can you please direct me to the relevant files and directories?

Thanks for the help