[DRAFT] Queue Semantics support in Kafka Ingestion#19311

Open

Shekharrajak wants to merge 18 commits intoapache:masterfrom

Shekharrajak:feature/kafka-share-group-ingestion

Commits on Apr 14, 2026

Add AcknowledgingRecordSupplier interface and AcknowledgeType enum for queue-semantics ingestion
Shekharrajak
committed
Add ShareGroupIndexTask and ShareGroupIndexTaskIOConfig for Kafka share group ingestion
Shekharrajak
committed
Add KafkaShareGroupRecordSupplier wrapping KafkaShareConsumer with explicit acknowledgement
Shekharrajak
committed
Add ShareGroupIndexTaskRunner with poll-parse-publish-ack ingestion loop
Shekharrajak
committed
Register ShareGroupIndexTask in KafkaIndexTaskModule and bump Kafka client to 4.2.0
Shekharrajak
committed
Add unit tests for ShareGroupIndexTaskIOConfig, KafkaShareGroupRecordSupplier, and ShareGroupIndexTask
Shekharrajak
committed
Add E2E test for share group ingestion with embedded Druid cluster and Kafka
Shekharrajak
committed
Add share group ingestion documentation with usage guide and examples
Shekharrajak
committed
Add ShareGroupKafkaResource with share group broker config for E2E tests
Shekharrajak
committed
Fix Kafka 4.x test compatibility: stub TestBroker, update ConsumerRecord constructors, add mockito dep
Shekharrajak
committed
Fix IOConfig test: add type field to JSON deserialization test
Shekharrajak
committed
Fix unit tests: add TimestampSpec to DataSchema, use multi-topic KafkaTopicPartition
Shekharrajak
committed