kafka indexing service

Hi,

I have included ‘druid-kafka-indexing-service’ in my extension and also created supervisor spec and submitted it. But how to start it and how to send data from kafka topic to that supervisor spec.

Thanks,

Monica

Hi Monica
you can submit your supervisor by:

curl -X POST -H ‘Content-Type: application/json’ -d @supervisor-spec.json http://localhost:8090/druid/indexer/v1/supervisor

details: http://druid.io/docs/latest/development/extensions-core/kafka-ingestion

thnx

Hi,

Yes I done this only but after that how to send data from kafka topic to the supervisor.

Thanks

in the supervisor spec you have specified the port and the kafka topic. check if kafka is sending on the same port and if this match simple send you data to this kafka topic. Or do I don’t understand you problem?

The issue is resolved.

Thanks