kafka消费者指定分区
String topic = "test"; TopicPartition partition0 = new TopicPartition(topic, 0); TopicPartition partition1 = new TopicPartition(topic, 1); consumer.assign(Arrays.asList(partition0, partition1));
-
当手动管理消费分区时，即使GroupID是一样的，Kafka的组协调器都将不再起作用
-
如果消费者失败，也将不再自动进行分区重新分配