欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Kafka安装遇到的问题

程序员文章站 2022-06-14 09:26:40
...

安装好后 可以创建topic,也可以查询,但是生产者发送消息的时候失败:Error Error when sending message to topic testTopic with key:null,value:1 bytes with error:(org.apache.kafka.clientsproducer.internals.ErrorLoggingCallback)

有没有考虑是不是你的生产者消费者写的有问题呢  用方案3的测试命令试试

kafka的基本操作:

1.创建topic:
./bin/kafka-topics.sh --create --zookeeper DM-147:2181,DM-148:2181,DM-149:2181 --replication-factor 3 --partitions 3 --topic testTopic
2.查看topic:
./bin/kafka-topics.sh --list --zookeeper DM-147:2181,DM-148:2181,DM-149:218
3.启动生产者:
./bin/kafka-console-producer.sh --broker-list DM-147:2181,DM-148:2181,DM-149:2181 --topic testTopic150
启动消费者:
./bin/kafka-console-consumer.sh --bootstrap-server DM-147:2181,DM-148:2181,DM-149:2181 --topic testTopic150
kafka版本查看:
find ./libs/ -name \*kafka_\* | head -1 | grep -o '\kafka[^\n]*'

百度方案:

1.保持自己broker.id  和zookeeper的myid一致;

2.按照这个解决方法,检查了三台kafka服务的配置,配

相关标签: # kafka