kafka消息消費原理

消費端如何指定消費的分區 通過下面的代碼，就可以消費指定該 topic 下的 0 號分區。其他分區的數據就無法接收 // 消費指定分區的時候，不需要再訂閱 //kafkaConsumer.subscribe(Collections.singletonList(topic)); // 消費指定的分區 TopicPartition topicPartition=newTopicPartition(to

>>阅读原文<<