kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker

Question

4-5 Kafka单节点单broker的部署及使用 章节中 Kafka的建议版本是0.9.0.0，

10-9 Direct方式整合之Spark Streaming应用开发及本地环境测试 章节中事件报错如下：

Exception in thread "main" java.lang.ClassCastException: kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker

Answer 1

weixin_慕妹8043461 2020-04-05 03:36:18

优秀的解答

Answer 2

提问者 hwbaker 2018-02-19 13:22:10

<dependency>

            <groupId>org.apache.kafka</groupId>

            <artifactId>kafka_2.11</artifactId>

            <version>${kafka.version}</version>

        </dependency>

把这段注释掉

注释掉就好了，不太明白为什么

• 慕尼黑5219940 #1

  你太厉害了，这都给你找到原因了，你还别说，真的是这个包引起的，我觉得可能是两个包都用StringDecoder, 它先用了版本不对的上面的那个依赖的kafka的jar包，注释掉就引用版本相符的了

Answer 3

提问者 hwbaker 2018-02-08 16:32:29

1、重新下载 kafka_2.11-0.8.2.1.tgz，版本0.8.2.1，更改环境变量:

export KAFKA_HOME=/opt/kafka_2.11-0.8.2.1

export PATH=$KAFKA_HOME/bin:$PATH

2、修改IDEA中pom.xml

<kafka.version>0.9.0.0</kafka.version>  改为 <kafka.version>0.8.2.1</kafka.version>

Answer 4

Michael_PK 2018-02-08 16:23:14

这个问题你百度下或者找下问答区的，以前有这个问题，解决过的