 https://github.com/apache/rocketmq-streams/pull/96
