Kafka发送消息失败原因
Kafka发送消息方法如下：
Properties properties = new Properties();
properties.put("zookeeper.connect", "server1:2181");
properties.put("serializer.class",StringEncoder.class.getName());
properties.put("metadata.broker.list","server1:9092");
ProducerConfig config = new ProducerConfig(properties);
Producer<String, String> producer = new Producer<String, String>(config);
producer.send(new KeyedMessage<Integer, String>("
", "Hello Kafka"));
运行程序出现如下错误：
Exception in thread "Thread-0" kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)
at kafka.producer.Producer.send(Producer.scala:76)
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
atits.kafka.Producer.run(Producer.java:46)
问题原因：
需要改动kafka安装目录下config文件夹下的server.properties中的以下两个属性
zookeeper.connect=localhost:2181改成zookeeper.connect=ip or domainname:2181
以及默认注释掉的
#host.name=localhost改成host.name=ip or domainname
重新启动kafka：
bin/kafka-server-start.sh config/server.properties &
发送消息成功
在kafka安装目录下执行下列语句查看kafka reciever是否收到消息
bin/kafka-console-consumer.sh --zookeeper [ip or domainname]:2181 --topic [topic name] --from-beginning
最新文章
- PRINCE2特征（三）
- initialization & finalization
- POJ1155 TELE（树形DP）
- SrcollView分页加载数据（第二种方法 自定义listView）
- Nginx初始化过程总结
- 机房收费系统之处理流程图与DFD图
- [CODEVS1697]⑨要写信
- JavaScript中的Date
- 计算BMI指数的小程序
- [H5]range对象的clone方法
- [TJOI 2013]拯救小矮人
- MySQL二进预编译制安装
- python selenium-webdriver 下拉菜单处理 （九）
- Json 文件中value的基本类型
- 【selenium】下拉框和弹出框处理
- Redis学习（5）-Jedis(Java操作redis数据库技术)
- 洛谷——P1894 [USACO4.2]完美的牛栏The Perfect Stall
- 20145335《java程序设计》第5次实验报告
- MySQL5.6之Index Condition Pushdown(ICP,索引条件下推)-Using index condition
- 有了Docker的程序猿们就能开启“上帝视角”？