Kafka发送消息失败原因
Kafka发送消息⽅法如下：
Properties properties = new Properties();
properties.put("t", "server1:2181");
properties.put("serializer.class",Name());
properties.put("metadata.broker.list","server1:9092");
ProducerConfig config = new ProducerConfig(properties);
Producer<String, String> producer = new Producer<String, String>(config);kafka为什么那么快
producer.send(new KeyedMessage<Integer, String>("
mytopic", "Hello Kafka"));
运⾏程序出现如下错误：
Exception in thread "Thread-0" kafkamon.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中的以下两个属性
以及默认注释掉的
#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

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。