1. 程式人生 > >kafka踩坑之消費者收不到訊息

kafka踩坑之消費者收不到訊息

生產者傳送訊息,客戶端始終消費不到

原因:

客戶端版本與服務端不一致

解決:

我這裡服務端使用的是: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伺服器的版本一一對應,否則,訊息傳送會失敗。