Weird error on machine restart when creating ConsumerConnector reference

Hi, *Following is the consumer related code*: Line#1 > ConsumerConnector consumer = kafka.consumer.Consumer.createJavaConsumerConnector(createConsumerConfig(zkConnect, consumerGroupId, offSetStorage)); private ConsumerConfig createConsumerConfig(String zookeeperConnectString, Str

[IMPORTANT] Questions related to AdminUtils thread safety

Hi, Could you please let me know if calls to "AdminUtils.topicExists" and "AdminUtils.createTopic" are thread-safe? Thank you, Siva.