Re: Embedded Kafka Broker Health Check

2016-08-22 Thread Enrico Olivelli
Hi, Can someone help on this topic? Thank you Enrico Il Mer 27 Lug 2016 12:26 Enrico Olivelli - Diennea < enrico.olive...@diennea.com> ha scritto: > Hi, > I'm running Kafka launching KafkaServerStartable inside my JVM (I'm using > version 0.10.0.0). > > I'm accessing the internal KafkaServer fie

Embedded Kafka Broker Health Check

2016-07-27 Thread Enrico Olivelli - Diennea
Hi, I'm running Kafka launching KafkaServerStartable inside my JVM (I'm using version 0.10.0.0). I'm accessing the internal KafkaServer field using reflection Field serverField = kafkaServer.getClass().getDeclaredField("server"); serverField.setAccessible(true); KafkaServer server = (KafkaServer)