Kafka Transaction with IBM MQ transaction

Всем привет. Кейс следующий :

1 Открыть транзакцию Kafka

2 Открыть транзакцию MQ

3 отправить сообщение в топик кафка

4 отправить сообщениу в MQ

5 отправить сообщение в другой топик кафка

6 закрыть транзакцию Кафка

7 закрыть транзакцию МКу

Если происходит ошибка на каком-то шаге, то делаем роллбек

Как это можно осуществить ? Читал про ChainedTransaction но проблема в том что класс Deprecated. Есть какие-то другие варианты? Желательно с примерами.


Ответы (0 шт):