Spring Kafka 事务提交序列

Question

我有两个服务。用户调用 Service-A 的 REST 端点，该端点进行处理，在数据库中创建记录/条目，然后发送 Kafka 事件以便使用 Service-B。

我已经使用@Transactional 进行了注释，以便数据库提交和Kafka 提交同时发生。

Service-B 将接收 Kafka 事件，处理，并将更新后的事件发送回 Service-A。

在这种情况下，我看到 Service-A 中的某些更新失败，表明找不到记录/条目。是竞赛条件吗？

由于ChainedKafkaTransactionManager 已被弃用，我如何确保首先发生数据库提交，然后是 Kafka 提交？

“对于生产者发起的事务，随着事务同步，Kafka提交也会发生在DB之后。”来自加里·拉塞尔

在我的场景中，由于事务不是由 Kafka 发起的，我该如何撤销提交？

@Transactional("dstm")
public void someMethod(String in) {
  Employee employee = this.repository.save(new Employee(in));
  if(employee.isSomeCondition()) {
    sendToKafka(employee);
  }
}

Answer 1

其实这里有一个很好的例子，你可以在这里配置多个数据源的事务处理：https://docs.spring.io/spring-kafka/docs/current/reference/html/#ex-jdbc-sync

另一个可能导致问题的问题是您的消费者的隔离级别。你把它改成 read_committed 了吗？