生产者发送消息,客户端始终消费不到

原因:

客户端版本与服务端不一致

解决:

我这里服务端使用的是:kafka_2.10-0.8.2.1.tgz,客户端原来使用的是0.8.1,需要改为:

<dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka_2.9.2</artifactId>
        <version>0.8.2.1</version>
</dependency>

使用kafka的时候要注意,kafka客户端(kafka-client)的版本要和kafka服务器的版本一一对应,否则,消息发送会失败。

Logo

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

更多推荐