availability
Hey Hohl,
I use *partitionsFor
<http://kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#partitionsFor%28java.lang.String%29>*
method to monitor the partition info for particular topics
On Tue, Dec 15, 2015 at 11:27 AM, Hohl, Ken <kh...
We want to be able to monitor the ability to send messages to Kafka topics. We
want to be aware of the inability to do so before the time we attempt to send a
message. What we're looking for is something like a heartbeat. The reason we
need this is that in our deployment environment, Kafka
