Kafka 发送消息失败

在使用brew services start kafka 成功启动kafka后，
执行发送消息会有提示以下，无法发送消息。

kafka-console-producer --broker-list localhost:9092 --topic test1
[2020-10-09 20:46:34,131] WARN [Consumer clientId=consumer-console-consumer-76912-1, groupId=console-consumer-76912] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
[2020-10-09 20:46:34,885] WARN [Consumer clientId=consumer-console-consumer-76912-1, groupId=console-consumer-76912] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

查看kafka启动日志(mac brew安装)，和bin目录在同一级

cd /usr/local/Cellar/kafka/2.6.0/libexec
ls
bin    config libs   logs

如果不知道日志文件在哪里可以搜索server.log
日志报错

kafka.common.InconsistentClusterIdException: The Cluster ID PLRSHbe7QESsqnyqO2JJsw doesn't match stored clusterId Some(RoyCX4R1TYOGg3GoNsoxNg) in meta.properties. The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong.at kafka.server.KafkaServer.startup(KafkaServer.scala:235)at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)at kafka.Kafka$.main(Kafka.scala:82)at kafka.Kafka.main(Kafka.scala)
[2020-10-09 21:03:36,766] INFO shutting down (kafka.server.KafkaServer)

解决办法：
删除 /usr/local/var/lib/kafka-logs文件。

如果在bin目录下直接执行./kafka-server-start.sh …/config/server.properties
会直接控制台会打印上面的报错。

Kafka 发送消息失败相关推荐

在idea中往Kafka发送消息失败
今天在学习Kafka整合Springboot项目的时候,往Kafka发送消息,消费者一直消费不到,ip地址,端口号,防火墙的状态都没有发现问题.后来发现是因为idea没有连接到虚拟机的,一直在找本机的 ...
物联网架构----EMQ-Hook了解、连接Kafka发送消息
物联网架构----EMQ-Hook了解.连接Kafka发送消息 1. 前言按照我自己设计的物联网框架,对于MQTT集群中的所有消息,是要持久化到磁盘的,这里采用一个消息队列中间件Kafka作为数据缓 ...
RabbitMQ消息队列，发送消息失败、消息持久化、消费者失败处理方法和发送消息
项目是使用springboot项目开发的,前是代码实现,后面有分析发送消息失败.消息持久化.消费者失败处理方法和发送消息解决方法及手动确认的模式先引入pom.xml <!--rabbitmq- ...
kafka发送消息的三种方式
1.发后即忘(fire-and-forget) 只管往kafka发送消息而并不关心消息是否正确到达.正常情况没什么问题,不过有些时候(比如不可重试异常)会造成消息的丢失.这种发送方式性能最高,可靠性最 ...
springboot kafka发送消息
场景:kafka发送消息,并且根据消息发送的不同渠道和消息类型(例如发送到WX,DingDing,邮箱),采取不同的线程池处理 1.引入依赖 <dependency><groupId ...
Kafka 发送消息
– Start 点击此处观看本系列配套视频在上个例子中,我们使用了脚本来发送消息,来吧,让我们来自己写点代码来发送消息.首先还是按照上个例子,先启动 ZooKeeper 和启动 Kafka bor ...
msg计算机指令怎样用,WIN7里使用msg命令发送消息失败
使用服务:WIN7里使用msg命令发送消息一.msg语法 MSG {username | sessionname | sessionid | @filename | *} [/SERVER:serv ...
netty心跳过程中发送消息失败_netty心跳机制和断线重连(四)
心跳是为了保证客户端和服务端的通信可用.因为各种原因客户端和服务端不能及时响应和接收信息.比如网络断开,停电或者是客户端/服务端高负载. 所以每隔一段时间客户端发送心跳包到客户端服务端做出心 ...
kafka发送消息至指定分区
前言在实际使用中,我们可能需要对某个topic下不同的消息进行分类管理,比如确保消费的顺序性,在这种场景下,我们可以首先确保生产者发送消息到指定的分区即可本文的测试基于docker搭建的一个双节点 ...

Kafka 发送消息失败

Kafka 发送消息失败相关推荐

最新文章

热门文章