Apache Druid

A consumer group is created with the partitions in a task, and Druid then relies on the consumer to poll the records.
The class `KafkaRecordSupplier` has more details if you are interested

Inside the consumer group created for a particular task, what is the number of consumers inside it? Is it equal to the number of partitions?

Apologies, I meant to say that a single consumer is created per task

Can you point to the link in the documentation where I can read in detail

<https://druid.apache.org/docs/latest/development/extensions-core/kafka-ingestion.html>

<https://github.com/apache/druid/blob/master/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaRecordSupplier.java|https://github.com/apache/druid/blob/master/extensions-core/kafka-indexing-service[…]n/java/org/apache/druid/indexing/kafka/KafkaRecordSupplier.java>

Each streaming ingestion task has a record supplier. In the case of the KafkaRecordSupplier, please refer to the method: `poll`