Load from Kafka: UnsupportedVersionException. Failed to sample data: The broker does not support LIST_OFFSETS with version in range[2,4]. The supported range is [0,1].

[mingzeng21]

Load from Kafka: UnsupportedVersionException. Failed to sample data: The broker does not support LIST_OFFSETS with version in range[2,4]. The supported range is [0,1].

Affected Version

The Druid version is 0.15.0

Description

I am trying to load data from Kafka using Druid Kafka ingestion. I get error message: UnsupportedVersionException. Failed to sample data: The broker does not support LIST_OFFSETS with version in range[2,4]. The supported range is [0,1].

I know that the version of the Kafka broker should be 0.10.x or newer.
I am using a CDH cluster. The Kafka version shown on CM is 0.10.2+kafka2.2.0. The KAFKA dir under cloudera/parcels is KAFKA-2.2.0-1.2.2.0.

It seems like my Kafka version has met the requirement. But why this fatal exception has happened?

[ighack]

I have same exception
my kafak is kafka_2.11-0.10.1.0

[jihoonson]

Hi, the minimum supported Kafka version is changed to 0.11.0 in 0.15.0. See https://github.com/apache/incubator-druid/releases/tag/druid-0.15.0-incubating for more details.

[averma111]

Hi Team,

I am new to Druid 0.15.1. If the issue is fixed. Where I can get the patch to fix this?.

Thanks,
Ashish