Ady Liu
Ady Liu
需要在 producer/consumer出设置，目前是 producer和consumer服务解析hostname
如果是在一台机器上执行的话，hosts文件会解析的，跨机器如果没有域名就需要ip地址
java有DNS缓存，如果eclipse的java程序hosts没有生效，需要重启下eclispe。 另外，如果服务器(broker)没有域名的话，建议使用ip地址，这样每一个producer/consumer都无需设置hosts文件
eclipse这台机器上ping ZK1
没问题。 这段代码的意思是 如果需要消费消息，那么消费的消息需要重新以Producer的方式发送出去。 其实是镜像拷贝功能。
能把Exception发出来看看么？
我用zookeeper 3.5测试了，没发现问题。我需要更多的上下文信息。欢迎你用imxylz#gmail与我联系。
消息是支持分布式以及分片的，当多个groupid相同的消费者同时消费一个topic的时候，这小消费者之间就是竞争的关系。每一个消费者消费的分片消息都是不重叠的，也就是queue的方式。每一条消息只能被一个消费者消费。
肯定可以的。因为zk记录了各个消费者的偏移量，消费者再启动时会从上次的偏移量开始消费消息。 如果有疑问，可贴出代码来分析下。
broker对应的topic有几个分区partition？ ExecutorService executor = Executors.newFixedThreadPool(3); 全部消费端的线程数加起来和 要比 broker的所有partition加起来和要多。 另外，有几个消费端？每个消费端都不消费消息么？ 日志有什么WARN 提示？