kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.

Kafka版本是 2.11-1.0.1

今天用Java操作Kafka，生产者的时候，报

Exception in thread "main" Failed to send requests for topics test with correlation ids in [0,3]
kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
阅读更多   2018/7/30 posted in  Kafka

Kafka单机安装

本文安装的Kafka是单机版，版本是kafka_2.11-1.0.1，使用的系统是CentOS 7.4 64位

进入src目录

cd /usr/local/src

下载Kafka

wget http://archive.apache.org/dist/kafka/1.0.1/kafka_2.11-1.0.1.tgz

解压下载的Kafka文件

tar -zxvf kafka_2.11-1.0.1.tgz
阅读更多   2018/7/25 posted in  Kafka

Copyright ©