Потребитель продолжает вызывать метод опроса, даже если он не подключен к брокеру - PullRequest
Новая
       15

Потребитель продолжает вызывать метод опроса, даже если он не подключен к брокеру

0 голосов
/ 06 ноября 2018

Я учу кафку с простым потребителем. Я настроил неправильный URL сервера. При использовании метода assign клиника продолжает опрос и печатает dddddddd : 

    kafkaConsumer.assign(Arrays.asList(topicPartition));
    kafkaConsumer.seekToBeginning(Arrays.asList(topicPartition));
    while (true) {
        System.out.println("xxxxxxxx");
        kafkaConsumer.poll(1000);
        System.out.println("dddddddd");
    }

Однако при использовании подписки опрос зависает и не переходит к следующей инструкции: 

    kafkaConsumer.subscribe(Arrays.asList("dddd"));
    // kafkaConsumer.seekToBeginning(Arrays.asList(topicPartition));
    while (true) {
        System.out.println("xxxxxxxx");
        kafkaConsumer.poll(1000);
        System.out.println("dddddddd");
    }

Почему клиент продолжает опрос при использовании assign / seekToBeginning? Я ожидаю, что опрос будет зависать.

...