Мое приложение производителя публикует сообщения в 2 темах за 1 транзакцию.Есть не транзакционные сообщения, созданные для этих тем тоже.Я хочу, чтобы мое потоковое приложение совместно использовало транзакционные сообщения.
T: msg N транзакции: MSG нет транзакции
Prod1: T1 (topic1), T2 (topic2) Prod2: N1, N2, N3.... Nn (сообщения постоянно публикуются в теме1 и теме2 все время)
Я хочу использовать T1 и T2 вместе на стороне потребителя без задержки в пакете.По сути, я не хочу, чтобы бомбардировка нетранзакционных сообщений влияла на мои транзакционные сообщения.