[LIG-14]

[JasonThon]

1. modify redis extractor;
2. add partition and group config for kafka connector
3. add a new example;
4. for KeyedDataflow; operator should return also keyed

[codecov-commenter]

Codecov Report

Merging #11 (33539c6) into master (ace4a4d) will increase coverage by 0.03%. The diff coverage is n/a.

@@            Coverage Diff             @@
##           master      #11      +/-   ##
==========================================
+ Coverage   67.35%   67.39%   +0.03%     
==========================================
  Files          20       20              
  Lines        1547     1561      +14     
==========================================
+ Hits         1042     1052      +10     
- Misses        505      509       +4     

Impacted Files	Coverage Δ
src/common/tests/test_kafka.rs	89.65% <0.00%> (-3.21%)	:arrow_down:
src/common/src/kafka.rs	86.36% <0.00%> (-2.01%)	:arrow_down:
src/stream/src/actor.rs	56.68% <0.00%> (-0.38%)	:arrow_down:
src/common/tests/test_mysql.rs	100.00% <0.00%> (ø)
src/stream/tests/test_sinks.rs	99.21% <0.00%> (+0.03%)	:arrow_up:
src/common/src/db.rs	78.57% <0.00%> (+3.57%)	:arrow_up:

:mega: We’re building smart automated test selection to slash your CI/CD build times. Learn more