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) serverField.get(kafkaServer);
byte state = server.brokerState().currentState();
What is the best way to ask KafkaServer its state ?
I see that the 'brokerState' is not very useful
Sometimes the server stops working, for instance due to ZK session expiration,
but the broker remains in RunningAsBroker state.
Second question ? If it is not possibile to dig into Broker status (and in fact
I would prefer not to do), is there some flag to auto-kill the broker in case
of serious problems (ZK, Disk space....)
I can send some logs, but I prefer to treat it as a blackbox, as far as it is
possible
Thank you
--
Enrico Olivelli
Software Development Manager @Diennea
Tel.: (+39) 0546 066100 - Int. 925
Viale G.Marconi 30/14 - 48018 Faenza (RA)
MagNews - E-mail Marketing Solutions
http://www.magnews.it
Diennea - Digital Marketing Solutions
http://www.diennea.com
________________________________
Iscriviti alla nostra newsletter per rimanere aggiornato su digital ed email
marketing! http://www.magnews.it/newsletter/
The information in this email is confidential and may be legally privileged. If
you are not the intended recipient please notify the sender immediately and
destroy this email. Any unauthorized, direct or indirect, disclosure, copying,
storage, distribution or other use is strictly forbidden.
