This indeed a bug, but it has been fixed in the master/develop branch of Apache/rocketmq repo, but we have't update maven repository, you can checkout source code and build it, or use the old version 4.3.0 instead.
viktorzhong <[email protected]> 于2018年9月23日周日 下午9:44写道： > I'm trying the transaction example on the website, the > executeLocalTransaction method returns COMMIT_MESSAGE every time. > > @Override > public LocalTransactionState executeLocalTransaction(Message msg, Object > arg) { > return LocalTransactionState.COMMIT_MESSAGE; > } > > The issue is the messages are delayed about 30s(on broker), I'm using > 4.3.1 and 2m2s. > Is there any tip about this? > > — > You are receiving this because you are subscribed to this thread. > Reply to this email directly, view it on GitHub > <https://github.com/apache/rocketmq/issues/474>, or mute the thread > <https://github.com/notifications/unsubscribe-auth/Alv-C7jLU-782WzBhKB9dVrLqOAZ9TH_ks5ud5BZgaJpZM4W1tN9> > . > [ Full content available at: https://github.com/apache/rocketmq/issues/474 ] This message was relayed via gitbox.apache.org for [email protected]
