Hi Team, Reg : Custom extension for realtime data ingestion In Druid, is it possible to create a new extension for retrieving data from a Kafka server using our custom Kafka client framework instead of relying on the default extension (druid-kafka-indexing-service)? If so, could anyone kindly provide the guidance/documentation/sample code for our reference? This would greatly assist us in our case. Thanks you, Ananthan.A

I don't have that level of knowledge. Have you looked at these docs?