ywengineer
ywengineer
那对Consumer分组的意义又在哪里呢？ 能留个IM么？
以下是2个Consumer 1、不同组，消费同一topic，始终只有一个Cosumber能收到消息。另一个Consumer Group的FetchRunnable线程状态一直为Wait. 2、停掉一个Consumer Group，另一个Consumer Group的FetchRunnable线程状态一直为Wait. 3、不同Group消费不同topic也不行，另一个Consumer Group的FetchRunnable线程状态一直为Wait. 如果Consumer2的goupid与Consumer1相同，则可以消费不同的topic. Consumer2: JafkaConsumer consumer2 = new JafkaConsumer("group-2", "101.37.19.118", 2181) { @Override protected void onMessage(JafkaMessage message) { System.out.println("consumer 2 onMessage => " +...