apache/rocketmq-streams

Issues

• Multiple sinks cannot be implemented

  #311 opened 9 months ago by 380828801
  0

• support subscribe topic from first

  #272 opened a year ago by ni-ze
  3

• OSAPP 2023-local storage optimization

  #309 opened a year ago by ni-ze
  0

• polish example

  #308 opened a year ago by ni-ze
  0

• Add 2 user examples using different `window` type and `keyBy` by more than one keys

  #304 opened a year ago by elenacliu
  0

• The `WordCount` example cannot run successfully

  #305 opened a year ago by elenacliu
  1

• WordCount demo dosen't work well

  #300 opened a year ago by xiaoweige1101
  1

• what's the difference between `AccumulatorSupplier.java` and `AggregateSupplier.java`?

  #298 opened a year ago by elenacliu
  1

• There's no difference between the implementation for the two `count` functions of `GroupedStreamImpl`

  #299 opened a year ago by elenacliu
  2

• Will there be a complete test framework in the future to test the functions?

  #285 opened a year ago by elenacliu
  2

• Do not process data coms from removed MessageQueue.

  #281 opened a year ago by ni-ze
  2

• The logic of watermark judging whether to solve the data may result in missing data.

  #290 opened a year ago by starmilkxin
  2

• Discard data because of delay

  #294 opened a year ago by ni-ze
  0

• Why the termination condition is 'start > valueTime - sizeInterval' instead of 'start >= valueTime - sizeInterval' ?

  #289 opened a year ago by starmilkxin
  1

• Messages which before RocketMQStream created will be consumed

  #287 opened a year ago by longbowen
  11

• Support flatMap function in GroupedStream

  #247 opened a year ago by ni-ze
  3

• Finish data processing when function return null.

  #246 opened a year ago by ni-ze
  5

• Instance reports an error, after another instance closed.

  #286 opened a year ago by longbowen
  1

• Add constructor

  #283 opened a year ago by ni-ze
  0

• multi-instance applications consumers problem

  #279 opened a year ago by comecny
  1

• UnsatisfiedLinkError

  #278 opened a year ago by Jerryunclock
  2

• Support sum function in WindowStream

  #250 opened a year ago by ni-ze
  1

• Support max function in WindowStream

  #248 opened a year ago by ni-ze
  1

• Support min function in WindowStream

  #249 opened a year ago by ni-ze
  1

• Why does flatMap interface return RStream<T> instead of RStream<VR> ？

  #268 opened a year ago by huangql
  1

• polish double stream join

  #270 opened a year ago by ni-ze
  0

• Support avg function in WindowStream

  #251 opened a year ago by ni-ze
  4

• Add watermark in session window

  #267 opened a year ago by ni-ze
  0

• store watermark

  #265 opened a year ago by ni-ze
  0

• The idle window does not trigger

  #263 opened a year ago by ni-ze
  0

• Modify the configure of ObjectMapper

  #261 opened a year ago by ni-ze
  0

• Use thread name as rocksdb path

  #257 opened a year ago by ni-ze
  0

• keep state topic consistent with source topic

  #255 opened a year ago by ni-ze
  0

• Adjust RSQLDB

  #253 opened a year ago by ni-ze
  0

• Aadd flatmap, add tostring, modify the key of sink topic

  #244 opened a year ago by ni-ze
  0

• Add quick start

  #234 opened 2 years ago by ni-ze
  0

• Add new feature and fix bug

  #232 opened 2 years ago by ni-ze
  0

• [RIP-58]RocketMQ Streams improvement

  #230 opened 2 years ago by ni-ze
  1

• Whether RocketMQ streams consider retaining only RocketMQ source/sink ?

  #220 opened 2 years ago by sunxiaojian
  3

• Support data deserialize with schema for RocketMQSource

  #205 opened 2 years ago by MatrixHB
  0

• Duplicate Unit Test

  #214 opened 2 years ago by selectbook
  0

• support custom function

  #213 opened 2 years ago by ni-ze
  0

• support session and hop window

  #210 opened 2 years ago by ni-ze
  0

• Commit offset error, because consume shutdown.

  #208 opened 2 years ago by ni-ze
  0

• support nest join

  #199 opened 2 years ago by ni-ze
  0

• The demo runs failed when using JDK11

  #202 opened 2 years ago by MatrixHB
  0

• Error when use fromCollection.

  #196 opened 2 years ago by ni-ze
  1

• homework

  #182 opened 2 years ago by Jacob-Mr-Yang
  0

• Make a compatible version with rsqldb

  #187 opened 2 years ago by ni-ze
  0

• type inconsistency

  #184 opened 2 years ago by ni-ze
  2