Каким должен быть TransactionIdPrefix для потребителя с несколькими весенними загрузками / производит приложения, которые подключены к kafka (3 брокера)

Question

У меня есть несколько приложений с весенней загрузкой, которые подключены к kafka (объединены с 3 брокерами), а также встроена синхронизация транзакций (chainedKafkaTransactionManager).поэтому я хочу знать, должен ли я дать одно и то же значение TransactionIdPrefix в конфигурации kafka для всех приложений или разных приложений.

Я попытался дать случайно сгенерированный TransactionIdPrefix для каждого приложения.но я думаю, что в какое-то время в многопоточной среде в методе Listeners это будет принимать старые данные из базы данных (репозитории jpa), это проблема из-за различий TransactionIdPrefix?

Answer 1

Это зависит; если они представляют собой несколько экземпляров одного и того же приложения, а транзакции запускаются потребителями, префикс должен быть одинаковым, чтобы ограждение зомби обрабатывалось правильно при перемещении разделов из одного экземпляра в другой после перебалансировки.

Если транзакции запускаются производителями, префикс должен быть уникальным в каждом случае.

Если это разные приложения, они должны иметь разные префиксы независимо от того, с чего начинается транзакция.