rocketmq-streams-1.0.0-preview

What's Changed

• [ISSUE #29]added english descriptions of read.me by @Laura-monkey in #28
• [ISSUE 31] Change Chinese doc file path by @duhenglucky in #30
• AbstractChannel with two redundant method can not compile. by @ni-ze in #26
• [ISSUE #33]Exclude CI files in apache rat check by @duhenglucky in #32
• add license header by @duhenglucky in #36
• fix RocketMQ Source has no namesrv set error by @francisoliverlee in #35
• [ISSUE #37]Add Apache license and fix some naming problems by @caigy in #38
• fix some error and make a code style. by @ni-ze in #39
• test window exactly once success and fixed bugs by @yuanxiaodong in #43
• make a runnable example. by @ni-ze in #44
• [ISSUE #48]add bitset cache to optimize regex by @yuanxiaodong in #46
• add cache filter to excute quickly for script by @yuanxiaodong in #49
• some file lack of apace license. by @ni-ze in #52
• make a runnable example of window operator. by @ni-ze in #54
• add update logic for the DBSinker 、 upgrade the concat_ws function by @program-0 in #57
• Joinwindow bug fix by @xstorm1 in #61
• Add Sqlmode by @program-0 in #63
• support hyperscan and fixed bugs by @yuanxiaodong in #67
• [ISSUE #65]Polish RocketMQ topic create process and sink settings by @duhenglucky in #64
• add checkpoint storage by @cyril68 in #69
• Add a quick start which contain some examples. by @ni-ze in #68
• Add fingerprinting to the client by @program-0 in #77
• #73 #74 session window and count(distinct) implementation by @speak2me in #70
• #73 #74 session window and count(distinct) implementation by @speak2me in #71
• [ISSUE #76]Verify horizontal expansion capabilities of rocketmq-streams client. by @ni-ze in #75
• [ISSUE #73 #74] session window and count(distinct) implementation by @speak2me in #79
• [ISSUE #85] Recorrect example. by @ni-ze in #84
• add batch stream features and cycle schedule by @cyril68 in #81
• add 'synchronized', fix joinwindow firewindow issue by @xstorm1 in #83
• Window by @yuanxiaodong in #87
• fix(window) fix queuelist null pointer exception by @duhenglucky in #89
• changes by @speak2me in #91
• add dim&script&filter&kafka by @cyril68 in #93
• [ISSUE #95]Remove README-Chinese.md by @ni-ze in #94
• [ISSUE #97]Fix file source example by @ni-ze in #96
• [ISSUE #99] Add default rebalance strategy by @duhenglucky in #98
• [ISSUE #101]Fix example RocketMQSourceExample1 by @ni-ze in #100
• fix check failed issue by @duhenglucky in #102
• add example log4j config by @lizhiboo in #111
• Fix npe two streams & fix joinwindow's production donot be conducted by mainpipeline's following stages by @lizhiboo in #104
• add multi rocketmq source example by @lizhiboo in #106
• Fix join and Window issues， add the mqtt source and sink by @program-0 in #112
• [ISSUE #113]Multi rocketmq source example by @lizhiboo in #113
• [ISSUE #116] Fix bug and add join window example by @ni-ze in #115
• Release 1.0.0 by @program-0 in #119
• The year should be updated to 2022 in NOTICE file by @JacekJanur in #124
• bugfix_20220105 by @speak2me in #122

New Contributors

• @Laura-monkey made their first contribution in #28
• @ni-ze made their first contribution in #26
• @francisoliverlee made their first contribution in #35
• @caigy made their first contribution in #38
• @JacekJanur made their first contribution in #124

Full Changelog: https://github.com/apache/rocketmq-streams/commits/rocketmq-streams-1.0.0-preview