The Apache Kafka Consumer API

A post was split to a new topic: How to check lags for each partition of topics that a consumer group has subscribed to?