在调用Kafka Consumer API编程的时候出现 kafka.common.ConsumerRebalanceFailedException

来源：4-10 -Kafka Consumer Java API编程

王w77

2018-04-18

写回答

3回答

Michael_PK

2018-04-19

OK，多个框架整合一定要根据官方给的版本要求来，否则很多错

王w77

提问者

2018-04-19

修改了版本可以了，集群上之前装的kafka-2.12-0.10.2.1的，scala装2.10.2，结果生产者正常，消费者报错

改成kafka_2.11-1.1.0和scala2.11.8就可以了

Michael_PK

2018-04-19

参考下这个试试：https://stackoverflow.com/questions/22563401/rebalancing-issue-while-reading-messages-in-kafka?utm_medium=organic&utm_source=google_rich_qa&utm_campaign=google_rich_qa

Spark Streaming实时流处理项目实战

Flume+Kafka+Spark Streaming 构建通用实时流处理平台

1404 学习 · 571 问题

查看课程

相似问题

执行Kafka启动命令后JPS没有出现Kafka

回答 1

spark streaming 读取kafka的数据量不准确，请问是什么原因

回答 1

kafka JAR 包冲突

回答 4

关于kafka新版本的一个问题

回答 3

Kafka Producer python API编程报错

回答 1

打开慕课网App查看更多内容