The Consumer API allows applications to read streams of data from topics in the Kafka cluster.
Applications can consume data independently. Data is not deleted once it has been read.
Applications can scale horizontally and consume data in parallel.
A post was split to a new topic: How to check lags for each partition of topics that a consumer group has subscribed to?