rocketmq-streams-all-1.1.0

1. A new stream processing task construction process.
2. Removes the configurable module and makes code more clear.
3. Support custom serialization and deserialization.
4. A new stream processing process, unify the source and shuffle.

What's Changed

• add kafka module by @j-ching in #137
• bugfix list by @speak2me in #125
• Bump logback-core from 1.2.3 to 1.2.9 by @dependabot in #145
• Bump quartz from 2.2.1 to 2.3.2 by @dependabot in #139
• Bump junit from 4.12 to 4.13.1 by @dependabot in #141
• Bump commons-collections from 3.2.1 to 3.2.2 by @dependabot in #142
• fix example code 404 in README.md by @rocklau in #147
• Bump commons-io from 2.5 to 2.7 by @dependabot in #146
• Bump httpclient from 4.5.2 to 4.5.13 by @dependabot in #140
• Snapshot 1.0.2 by @j-ching in #148
• Snapshot 1.0.3 by @j-ching in #157
• [ISSUE #161] fix(example) add can_clear_resource in sql by @ni-ze in #160
• Bump gson from 2.8.5 to 2.8.9 by @dependabot in #158
• Bump fastjson from 1.2.9 to 1.2.25.sec10 by @dependabot in #143
• Bump fastjson from 1.2.25.sec10 to 1.2.83 by @dependabot in #166
• modify quick start by @ni-ze in #169
• [ISSUE #170] An example of real-time score statistics by @123liuziming in #171
• [ISSUE #184]fix(commons) type inconsistency by @ni-ze in #185
• [ISSUE #175] Corrects a spelling error in the word "stream" by @tongfs in #176
• [ISSUE #172][ISSUE #174]Modify the File Source Example; Update README; Fix incompatible types bug by @hyl-xidian in #173
• [RIP-35] Use rocketmq instead of mysql as state store by @ni-ze in #132
• [ISSUE #187]Merge from Snapshot 1.0.4 by @ni-ze in #186
• Add dependency in serviceLoad module by @ni-ze in #191
• Use Pair class of apache.commons.lang3 instead of javafx by @linfan in #193
• [ISSUE #196]fix(ChannelBuilder) add ChannelBuilder by @ni-ze in #195
• Use shade plugin to hide dependencies by @totalo in #194
• support join sql in rsqldb by @ni-ze in #197
• fix(left join) fix left join by @ni-ze in #198
• [ISSUE #199]Support rsqldb by @ni-ze in #200
• [ISSUE #202] adapt jdk11 by @MatrixHB in #204
• Resolve bug of concurrent modification by @ni-ze in #201
• [ISSue #208]Support rsqldb by @ni-ze in #207
• [ISSUE #210]support session and hop window by @ni-ze in #209
• [ISSUE #205] support message body converted into UserDefinedMessage with schema by @MatrixHB in #206
• support emit and watermark by @ni-ze in #211
• [ISSUE #213]fix(custom function) support utf by @ni-ze in #212
• [ISSUE #214] duplicate unit test by @selectbook in #215
• fix(common) modify name by @ni-ze in #217
• Add string schema and word-count example by @MatrixHB in #216
• feature(configuable) support store configuration in db by @ni-ze in #218
• fix(common) remove dipper by @ni-ze in #219
• maintain(doc) design by @ni-ze in #222
• support customized deserializer for dataStream from RocketMQ by @MatrixHB in #221
• fix(window) remove isSplitsReceiver by @ni-ze in #223
• modify email by @ni-ze in #226
• fix(common) remove slf4j-log4j12 by @ni-ze in #227
• [ISSUE #230][RIP-58]RocketMQ Streams improvement by @ni-ze in #229
• [ISSUE #232]add operator in groupByStream by @ni-ze in #231
• [ISSUE #234]Add quick start by @ni-ze in #233
• [doc] modify quick start by @ni-ze in #235
• [doc] modify quick start by @ni-ze in #236
• [doc] modify quick start by @ni-ze in #237
• modify version to 1.1.0-SNAPSHOT by @ni-ze in #238
• [doc] modify quick start by @ni-ze in #239
• [doc] modify quick start by @ni-ze in #240
• remove useless class by @ni-ze in #241
• add exception by @ni-ze in #242
• [ISSUE #244]Add flatmap, add tostring, modify the key of sink topic by @ni-ze in #243
• add example by @ni-ze in #245

New Contributors

• @dependabot made their first contribution in #145
• @rocklau made their first contribution in #147
• @123liuziming made their first contribution in #171
• @tongfs made their first contribution in #176
• @hyl-xidian made their first contribution in #173
• @linfan made their first contribution in #193
• @totalo made their first contribution in #194
• @MatrixHB made their first contribution in #204
• @selectbook made their first contribution in #215

Full Changelog: rocketmq-streams-1.0.1-preview...rocketmq-streams-all-1.1.0