初学Kafka遇到的问题:Wrong request type 18、 Error reading field ‘topic_metadata’: …

其实这两个错误的根本原因是一致的,都是Linux上的版本号与maven里面kakfa-client的版本号不对应的问题:
我在linux上面的kafka的版本号是:kafka_2.10-0.8.2.1

  1. 先给出第一个错误:这时候在pom文件里面配置的版本号是:<version>0.11.0.1</version>
    在这里插入图片描述

  2. 这是第二个错误:这时候在pom文件里面配置的版本号是:
    <version>0.9.0.1</version>
    这时候虽然在linux上的kafka-console-consumer上可以接受到java发送的消息,但java的控制台确报出下面的错误,看着挺难受的……
    在这里插入图片描述
    最后只能将pom文件里面的版本号换成

 <version>0.8.2.2</version>

最后终于没有错误了,唉,版本错误这个坑挺大的,小伙伴们要注意了

GitHub 加速计划 / li / linux-dash
10
2
下载
A beautiful web dashboard for Linux
最近提交(Master分支:8 天前 )
186a802e added ecosystem file for PM2 5 年前
5def40a3 Add host customization support for the NodeJS version 5 年前
Logo

旨在为数千万中国开发者提供一个无缝且高效的云端环境,以支持学习、使用和贡献开源项目。

更多推荐