инита транзакции? То есть если продюсеров 100 допустим то 6 партиций на 6 брокеров - это ок?
не блочит, там метка на сообщении вроде была
https://github.com/apache/kafka/blob/b2d8354e10b99959754e3b7fa495d0c758b78af6/core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala#L449 < но мета в лок же уходит?(
эм, тут только изменение данных в мете на полторы операции, или для вас это критично?
мы просто столкнулись с массовым отвалом транзакционных продюсеров по тайматуту пытаюсь найти в чем беда(
А до этого работало или только пробуете транзакции? И у вас стримы или еще чтото?
Работало / внезапно вылезли ошибки по конкуренту и старой эпохе. У нас без стримов eos транзакции
А transactional.id как сетапите для разных продьюсеров?
Обсуждают сегодня