我想使用kafka-console-producer cli工具向使用事务客户端的主题发送消息。我认为我的配置是正确的,但是当我运行cli工具时,我得到了以下异常:
java.lang.IllegalStateException: Cannot perform a 'send' before completing因此,看起来kafka控制台生产者,我相信它实例化了kafka.tools.ConsoleProducer类,要么没有调用initTransactions,要么在调用完成之前发送。我能做些什么来让kafka-co
我正在开发一个JEE应用程序,其中对"facade“bean的每个请求都应该运行一个事务。ùpdateSalaries()is a method invoked by the client, and whereinitializeTransaction()andcommitTransaction()`分别负责事务的获取不幸的是,事务管理应该更加透明:开发人员在编写业务方法时不应该关心的事情。
因此,用某种方式来“装饰”这些商业方法会很好,但我想不出有什么可能做到这一点。我想到的另一个可能的解决方案是在一个中央DataAccessB
如果我通过@Resource注释将一个存储库注入到一个容器托管bean中,该bean不会自动启动事务,一切都按预期的方式工作。(LocalTransactionImpl.java:112) at com.sun.enterprise.resource.ConnectorXAResource.commit(ConnectorXAResource.java(ConnectionImpl.java:1724) at com.sun.gjc.spi.LocalTransactionImpl.commit(LocalTransact