我在和一个简单的消费者学习Kafka。我配置了一个错误的服务器url。使用assign方法时,clinet保持轮询并打印dddd:
kafkaConsumer.assign(Arrays.asList(topicPartition));
kafkaConsumer.seekToBeginning(Arrays.asList(topicPartition));
while (true) {
System.out.println("xxxxxxxx");
kafkaConsumer.poll(1000);
System.out.println("dddddddd");
}
但是,使用subscribe时,轮询挂起,不移动到下一条指令:
kafkaConsumer.subscribe(Arrays.asList("dddd"));
// kafkaConsumer.seekToBeginning(Arrays.asList(topicPartition));
while (true) {
System.out.println("xxxxxxxx");
kafkaConsumer.poll(1000);
System.out.println("dddddddd");
}
为什么客户端在使用assign/seekToBegining时保持轮询?我想投票会暂停。
暂无答案!
目前还没有任何答案,快来回答吧!