kafka消息消费原理

消费端如何指定消费的分区 通过下面的代码，就可以消费指定该 topic 下的 0 号分区。其他分区的数据就无法接收 // 消费指定分区的时候，不需要再订阅 //kafkaConsumer.subscribe(Collections.singletonList(topic)); // 消费指定的分区 TopicPartition topicPartition=newTopicPartition(to

>>阅读原文<<