我正在尝试发布消息,但Apache Kafka已经宕机了。
像这样的紧急情况应该如何处理?
KafkaProducer::send()方法不会抛出任何可以处理的异常。生产者会将它们吞掉并记录错误,因此我会收到大量类似的错误消息,而且一切都会停滞,直到Kafka重新连接上。
KafkaProducer::send()方法不会抛出任何可以处理的异常。生产者会将它们吞掉并记录错误,因此我会收到大量类似的错误消息,而且一切都会停滞,直到Kafka重新连接上。
2014-03-31 09:38:23.752 ERROR o.a.kafka.common.network.Selector - Error in I/O:
java.net.ConnectException: Connection refused
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.7.0_51]
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739) ~[na:1.7.0_51]
at org.apache.kafka.common.network.Selector.poll(Selector.java:205) ~[kafka-clients-0.8.1.jar:na]
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:212) [kafka-clients-0.8.1.jar:na]
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:150) [kafka-clients-0.8.1.jar:na]
at java.lang.Thread.run(Thread.java:744) [na:1.7.0_51]