在卡夫卡自动重新连接不用担心

Question

我使用的是kafka-0.8.1.1版本,在这个版本中,自动重新连接不能通过java代码工作.我有属性文件

props.put("zookeeper.connect", "zoo1:2181,zoo2:2181");
props.put("group.id", KAFKA_GROUPID);
props.put("zookeeper.session.timeout.ms", "10000");
props.put("zookeeper.sync.time.ms", "200");
props.put("auto.commit.interval.ms", "1000");

当我启动消费者线程时,它连接到kafka服务器,在线程运行服务器之间丢失与kafka服务器的连接2小时.如果它重新连接kafka消费者没有收到任何消息,它也不会抛出任何错误流.

我们如何检测它丢失连接并自动重新连接消费者线程.

提前致谢