Kafka ingestion service in druid using supervisor task giving exception with FAILED status

Hello,
I tried using kafka ingestion service by submitting supervisor task to druid overlord process. But the task status is FAILED with the exception

org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'responses': Error reading array of size 486757, only 1069 bytes available

How can I resolve this exception? Which ‘responses’ field is it referring to?

Any help will be appreciated.

Thanks
Rajnandini


What version are your Kafka brokers? They’ll need to be 0.9 or better.

Thanks. Kafka broker was of older version. I got it working with version 9.0.1.

Rajnandini