初学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>

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

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐