Почему верблюжий Кафка ждет некоторое время после потребительского перебалансирования - PullRequest
0 голосов
/ 06 декабря 2018

Просматривая код потребителя Camel Kafka, можно увидеть, что в KafkaFetchRecords есть следующий код:

if (!first) {
       // skip one poll timeout before trying again
       long delay = endpoint.getConfiguration().getPollTimeoutMs();
       log.info("Reconnecting {} to topic {} after {} ms", threadId, topicName, delay);
       try {
            Thread.sleep(delay);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                    }
            }

Эта задержка имеет значение по умолчанию 5 секунд.Я пытаюсь понять, почему это требуется, а также возникнут ли какие-либо проблемы, если я уменьшу это до 1 секунды.Кажется, что 5 секунд - это много времени, для которого, насколько я понимаю, это будет полная остановка для любой обработки.

Ссылочный файл: https://github.com/apache/camel/blob/master/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java

Строка №: 198

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...