#apache-kafka #kafka-producer-api
Вопрос:
Как я понимаю, эта конкретная проблема может возникнуть, когда брокер не работает, и transaction.state.log.min.isr значение не выполняется, что приводит к producer.initTransaction() сбою, потому что он не может разговаривать с __transaction_state внутренней темой.
Я проверил нашу конфигурацию брокера кафки, и у нас был:
- 3 брокера, коэффициент репликации = 3
transaction.state.log.min.isr= 3
это значение transaction.state.log.min.isr казалось виновником, так как я подумал, что, возможно, один из 3 брокеров какое-то время находился в состоянии спада, что и вызвало эту проблему.
Но наша оперативная команда показала, что все брокеры работают уже несколько дней (нам дали скриншот времени безотказной работы брокера кафки из окна linux, где все развернуто).
Так что же еще может вызвать эту ошибку ?
Кроме того, возможно ли, что брокер может показать, что он работает, но все же что-то могло привести initTransaction() к тайм-ауту вызова?