Просматривая код потребителя 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