Как установить максимальную повторную попытку потребителя

Question

Хотелось бы знать, если существует свойство для потребителя, когда сервер kafka недоступен, чтобы указать, сколько раз ему следует пытаться подключиться к серверу kafka.

Я также пробовал:

.withProperty(ConsumerConfig.RECONNECT_BACKOFF_MAX_MS_CONFIG, "4000")
.withProperty(ConsumerConfig.RETRY_BACKOFF_MS_CONFIG, "500")
.withProperty(ConsumerConfig.RECONNECT_BACKOFF_MS_CONFIG, "500")

и, похоже, не работает. С настройками, приведенными выше, я ожидаю, что потребитель остановится после повторного подключения 4s.

Насколько мне известно, для производителя существует свойство retries.

Answer 1

Нет конфигурации для ограничения количества повторных попыток со стороны потребителя.

Однако есть параметры для контроля частоты переподключения

reconnect.backoff.max.ms

reconnect.backoff.ms

retry.backoff.ms