apache / rocketmq-streams

Apache rocketmq
https://rocketmq.apache.org/
Apache License 2.0
171 stars 82 forks source link

[ISSUS #309]OSAPP 2023-local storage optimization #306

Closed starmilkxin closed 1 year ago

starmilkxin commented 1 year ago

close #309

ni-ze commented 1 year ago
get(byte[] key)

put(byte[] key, byte[] value)

in RocksDBStore should be removed, use the interface ,which has a param columnFamily, is better.

if jobId start with watermark_key is forbidden, I think, should throws a exception when starting.