The broker does not support LIST_OFFSETS with version in range [2,4]. The supported range is [0,1]
"recentErrors": [
{
"timestamp": "2021-03-14T11:06:45.295Z",
"exceptionClass": "org.apache.kafka.common.errors.UnsupportedVersionException",
"message": "org.apache.kafka.common.errors.UnsupportedVersionException: The broker does not support LIST_OFFSETS with version in range [2,4]. The supported range is [0,1].",
"streamException": true
},
{
"timestamp": "2021-03-14T11:07:15.299Z",
"exceptionClass": "org.apache.kafka.common.errors.UnsupportedVersionException",
"message": "org.apache.kafka.common.errors.UnsupportedVersionException: The broker does not support LIST_OFFSETS with version in range [2,4]. The supported range is [0,1].",
"streamException": true
},
{
"timestamp": "2021-03-14T11:07:45.303Z",
"exceptionClass": "org.apache.kafka.common.errors.UnsupportedVersionException",
"message": "org.apache.kafka.common.errors.UnsupportedVersionException: The broker does not support LIST_OFFSETS with version in range [2,4]. The supported range is [0,1].",
"streamException": true
}
]
}
报错原因
我使用的druid-0.15.0 kafka版本kafka_2.11-0.10.1.0
版本不支持
看github上https://github.com/apache/druid/releases/tag/druid-0.15.0-incubating
解决方案
换高版本的kafka
我换的kafka_2.11-2.4.0
还没有评论,来说两句吧...