Spring云流Azure事件中心绑定器中的消息消耗后没有DB提交

Question

我有一个事件侦听器Spring boot应用程序，它执行从Azure事件中心主题读取操作-

我只是遵循了链接eventhubs活页夹示例中的示例。

@StreamListener(Sink.INPUT)
public void handleMessage(String message, @Header(AzureHeaders.CHECKPOINTER) Checkpointer checkpointer) {
    System.out.println(String.format("New message received: '%s'", message));
    myRepository.save(message); // No Insert operation triggered
}

在@StreamListener注释方法内执行的任何JPA save操作都不会将数据插入DB中。。

非常感谢您的任何提示。。我想我必须对事务同步（KafkaTransactionManager-JPATransactionManager）做些什么，但不确定。。

Answer 1

花了一天时间后，它开始工作了...创建了一个新的JpaTransactionManager并用它来创建一个TransactionTemplate。

并在从TransactionTemplate创建的新事务中执行my DB操作。

TransactionTemplate template = new TransactionTemplate(platformTransactionManager);
transactionTemplate.execute(new TransactionCallbackWithoutResult()
        {
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus status)
            {
                myRepository.save(message);
            }
        });