On Wed, May 9, 2012 at 5:47 PM, Ken Krugler <kkrugler_li...@transpac.com> wrote: > kafkaServerStartable.shutdown();
Ken, When you call shutdown() on KafkaServerStartable you should also call awaitShutdown if you're expecting your app / JVM to terminate (perhaps you are not). Also take into account that if the embedded KafkaServer instance in KafkaServerStartable throws an exception on shutdown it will call Runtime.getRuntime.halt(1) (not sure if you want this behaviour). I'm embedding a Kafka broker and producer in an experimental lib doing pretty much what you're doing except I use KafkaServer directly and make no use of ZK. Hope this helps, hmb. -- Hisham Mardam-Bey A: Because it messes up the order in which people normally read text. Q: Why is top-posting such a bad thing? A: Top-posting. Q: What is the most annoying thing in e-mail? -=[ Codito Ergo Sum ]=-
