服务没启 不就会报错么。发送超时。
我是新手,就按教程写了消费者和生产者类,启动kafka是可以传值和接收的,但是在kafka没启动的时候,send也不报错啊,一直在运行。。今天发现等了一段时间后生产者close了,但也没报错;但是消费者还是一直在运行,有什么解决办法吗。。
生产者发送不报错有2种情况。1、send()是非阻塞的。因此获取不到异常。可以改为阻塞式的发送,send().get(),这种可获得异常。2、设置callback,就是当发送完消息后,告知你是否发送成功。具体参见:https://www.orchome.com/451
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
服务没启 不就会报错么。发送超时。
我是新手,就按教程写了消费者和生产者类,启动kafka是可以传值和接收的,但是在kafka没启动的时候,send也不报错啊,一直在运行。。今天发现等了一段时间后生产者close了,但也没报错;但是消费者还是一直在运行,有什么解决办法吗。。
生产者发送不报错有2种情况。
1、send()是非阻塞的。因此获取不到异常。可以改为阻塞式的发送,send().get(),这种可获得异常。
2、设置callback,就是当发送完消息后,告知你是否发送成功。
具体参见:https://www.orchome.com/451
你的答案