v0.0.2-alpha

Major improvements

Feature

1. Support RocketMQ 4.x remoting protocol
2. Support delayed message
3. Implement topic-level TTL
4. Cluster mode

Tools

1. reset consume offset
2. cluster related operation
3. list group or topic

Observability

1. Introduce Metrics for stream module

What's Changed

• feat(s3stream/wal): group commit by @Chillax-0v0 in #422
• feat(s3stream): use put object when data size is less than 32MB by @superhx in #431
• fix(store): ignore operation with illegal argument in recovery process by @ShadowySpirits in #429
• feat: support pull for remoting protocol in the early stage by @daniel-y in #424
• feat: improve cache to avoid request collapsing by @lizhanhui in #430
• feat: implement topic retention period by @lizhanhui in #436
• feat: lookup topic/queue owner node id by @lizhanhui in #437
• feat(s3stream): support network inbound/outbound bandwidth throttle by @SCNieh in #438
• perf(s3stream/wal): use the memory pool by @Chillax-0v0 in #435
• feat: support getStreams for StreamManager by @wangxye in #432
• feat: filter out trimmed data on compaction by @SCNieh in #379
• feat: use protobuf-util to convert between protobuf message and json by @lizhanhui in #441
• feat: expose node config to StoreMetadataService by @lizhanhui in #442
• fix(s3stream/wal): no need to release recovered records internally by @Chillax-0v0 in #443
• fix(s3stream): fix memory leak by @SCNieh in #446
• fix(s3stream/wal): flush the file after write by @Chillax-0v0 in #447
• fix(s3stream/wal): add block into the writing list; update the start offset correctly by @Chillax-0v0 in #448
• feat(s3stream): cache evict by @superhx in #452
• feat(cli): support topic ttl in CreateTopic command by @ShadowySpirits in #439
• feat(s3stream/wal): merge write by @Chillax-0v0 in #454
• feat(proxy): support pull message request for remoting protocol by @ShadowySpirits in #449
• feat: controller handles planned termination by @lizhanhui in #457
• fix(s3stream): fix duplicated release by @superhx in #459
• feat: add protobuf rpc to request a node to terminate gracefully by @lizhanhui in #460
• test: specify test cases for s3wal and s3stream by @wangxye in #461
• feat: support shutdown broker gracefully by @daniel-y in #462
• feat: add CLI and partially implement graceful shutdown by @lizhanhui in #463
• perf(s3stream/wal): marshal records lazily by @Chillax-0v0 in #464
• fix: persist assignment status by @lizhanhui in #465
• fix: fix the empty of streamIds in getStreams by @wangxye in #466
• feat: implement leader transfer by @lizhanhui in #467
• feat(proxy): check client is supported for remoting protocol by @ShadowySpirits in #468
• chore: update test access key/secret by @lizhanhui in #451
• feat(store): support resetting consume offset by @TheR1sing3un in #434
• feat(store): support stream related metrics by @TheR1sing3un in #453
• fix(s3stream): prevent sort on unmodifiable list; delete unused code by @SCNieh in #472
• fix: expose port shifted by 1 by @lizhanhui in #473
• fix: stream domain object should use boxed type by @lizhanhui in #476
• feat(proxy): support pull orderly by @ShadowySpirits in #474
• fix: fix stream state when schedule queue/streams among nodes by @lizhanhui in #478
• fix(s3stream): force evict cache when OOM by @superhx in #479
• fix(s3stream): fix data block memory footprint by @superhx in #480
• feat(proxy): refactor long polling by @ShadowySpirits in #477
• feat: implement command to describe cluster by @lizhanhui in #485
• feat: pretty describe cluster output by @lizhanhui in #487
• feat: Cluster description shall include a summary section by @lizhanhui in #488
• feat: support for unified date management of metadata by @wangxye in #484
• fix: refine api of metadata store by @lizhanhui in #490
• fix: simplify stream mapper by @lizhanhui in #491
• fix(s3stream): fix kos issue389 index ouf of bound by @superhx in #494
• fix(s3stream): fix kos issue390 record out of order by @superhx in #495
• feat: support deploy in helm and kubeblock by @wangxye in #492
• feat(s3stream): stats bytebuf alloc by @superhx in #496
• feat(s3stream): add copyOnWrite interface to Writer by @SCNieh in #497
• fix(s3stream): fix kos issue403 repeated add backoff record by @superhx in #498
• feat(s3stream): isolate s3 readwrite by @superhx in #499
• feat(s3stream): limit s3 operator inflight request by @superhx in #500
• feat(s3stream): force split one wal at a time, limit memory consumpti… by @SCNieh in #501
• fix(s3stream): operator release by @superhx in #502
• feat(proxy): introduce TimerService by @ShadowySpirits in #493
• feat: expose create topic API to ProxyMetadataService by @lizhanhui in #503
• fix(s3stream): acquire deadlock by @superhx in #504
• feat: list topics by @lizhanhui in #505
• feat: implement list-group command by @lizhanhui in #507
• fix(s3stream): deadlock by @superhx in #508
• feat: implement update-group command by @lizhanhui in #512
• fix(s3stream/wal): fix memory leak during recovery by @Chillax-0v0 in #513
• feat: add command to delete{topic,group} by @lizhanhui in #514
• chore: register cli commands by @lizhanhui in #516
• feat: support addressOfNode in async by @wangxye in #517
• feat(s3stream): force exit when commit wal fatal error by @superhx in #520
• feat(store): support delayed message by @ShadowySpirits in #521
• refactor(store): optimize stream metrics' name by @TheR1sing3un in #518
• feat: support subscription mode for group by @lizhanhui in #522
• fix(s3stream): compaction fix by @SCNieh in #506
• chore: display queue-id prior to node-id by @lizhanhui in #523
• feat(proxy): limit client consumption mode by @ShadowySpirits in #524

Full Changelog: v0.0.1-alpha...v0.0.2-alpha