spring-cloud-stream生产者事务性

Question

@RequestMapping(method = RequestMethod.POST)
    @Transactional
    public Customer insertCustomer(@RequestBody Customer customer) {
        customerDao.insertCustomer(customer);
        source.output().send(MessageBuilder.withPayload(CustomerEventHelper.createSaveEvent(customer)).build());
        if (true) {
            throw new RuntimeException("rollback test");
        }
        return customer;
    }

CustomerDao.InsertCustomer调用回滚，但仍然发送了kafka消息。如果在customer事件上有一个使用者，该事件将客户插入数据仓库，则在转换回滚时，数据仓库和记录系统将不同步。有没有办法让Kafka活页夹在这里是事务性的？

Answer 1

Kafka活页夹不是事务性的，Kafka一般不支持事务。

我们确实打算解决Spring Cloud Stream1.1的事务管理问题:https://github.com/spring-cloud/spring-cloud-stream/issues/536。

但是，您目前甚至可以只在提交成功后通过如下所示注册事务同步来发送消息：

TransactionSynchronizationManager.registerSynchronization(
   new TransactionSynchronization(){
       void afterCommit(){                     
           source.output().send(MessageBuilder.withPayload(event).build());
    if (true) {

       }
});