java使用者即使未连接到代理,也会继续调用poll方法

5vf7fwbs  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(166)

我在和一个简单的消费者学习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时保持轮询?我想投票会暂停。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题