请问生产者send时有什么方法可以判断kafka服务是否已经启动吗?

SOX(╯°口°)╯ 发表于: 2017-12-22   最后更新时间: 2017-12-22 03:11:14   4,807 游览
发表于 2017-12-22
添加评论

服务没启 不就会报错么。发送超时。

我是新手,就按教程写了消费者和生产者类,启动kafka是可以传值和接收的,但是在kafka没启动的时候,send也不报错啊,一直在运行。。今天发现等了一段时间后生产者close了,但也没报错;但是消费者还是一直在运行,有什么解决办法吗。。

生产者发送不报错有2种情况。

1、send()是非阻塞的。因此获取不到异常。可以改为阻塞式的发送,send().get(),这种可获得异常。

2、设置callback,就是当发送完消息后,告知你是否发送成功。

具体参见:https://www.orchome.com/451

你的答案

查看kafka相关的其他问题或提一个您自己的问题