bob

看了代码，实现方式不严谨，硬件故障和断电等异常的情况根本就没考虑，这个开源框架理论上是不能100%解决分布式事务问题的，生产库就不要用了。

1. change "kafka.host = 127.0.0.1" , "kafka.port = 9092" to your kafka server ip and port. 2. cretate "Processing" topic in your kafka server. 3. start emqx and load plugin...

why use ''? try to change hostname to ip address .