Управление транзакциями между работой базы данных и службой обмена сообщениями Apache kafka - PullRequest
Новая
       20

Управление транзакциями между работой базы данных и службой обмена сообщениями Apache kafka

0 голосов
/ 21 сентября 2018

У меня есть один вариант использования.Как выполнить откат транзакции, когда сервер Kafka не работает? 

##Use Case:
@Transactional
public Integer add() {
  //Step 1
  Integer saved = xxxDAO.save(xxx); //Data base operation
  if (saved) {
  xxxService.send(data); //Kafka Producer Service method to send message to cosumer
  return 1;
}
return 0;
}

Транзакция базы данных прошла успешно после тайм-аута сервера Kafka (который составляет 60000 мс).Есть ли способ откатить всю транзакцию базы данных, когда сервер Kafka не работает?

...