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

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.


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.