kakfa Consumer can't rebalance after 5 retries

Question

JavaAPI中Kafka的消费者不能正确的连接到服务器的Kafka的队列。百度、google了很多都无法解决。

这是配置信息：

        props.put("zookeeper.connect", "XXXXXX:2181");

        //配置Zookeeper连接超时间隔

        props.put("zookeeper.connection.timeout.ms", "1000000");

        //配置Zookeeper的组id(The ‘group.id’ string defines the Consumer Group this process is consuming on behalf of.)

        props.put("group.id", "test-group");

        props.put("zookeeper.session.timeout.ms", "4000");

        props.put("zookeeper.sync.time.ms", "10000");

        props.put("auto.commit.interval.ms", "1000");

        props.put("rebalance.max.retries", "5");

        props.put("rebalance.backoff.ms", "1200");

这是错误日志：

Exception in thread "Thread-0" kafka.common.ConsumerRebalanceFailedException: test-group_yanyongdeMacBook-Pro.local-1471403173076-d34ac5a3 can't rebalance after 5 retries

    at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:660)

    at kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:967)

    at kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:254)

    at kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:84)

    at kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:96)

    at com.yany.consumer.ConsumerTest$MyConsumer.run(ConsumerTest.java:44)