What's Changed
- fix(kafka_issues563): check record continuous by @superhx in #833
- feat(s3stream): add strict check mode by @superhx in #834
- feat(s3stream): add read block cache context to trace status by @SCNieh in #835
- fix(s3stream): catch storage callback exception by @superhx in #836
- fix(s3stream): fix sanity check when stream is trimmed in the middle by @SCNieh in #837
- fix(kafka_issues562): fix duplicated release by @superhx in #838
- feat(s3stream): show s3 configure in DefaultS3Operator; add S3Utils by @mooc9988 in #840
- fix(s3stream): find in data block with real record size by @SCNieh in #839
- refactor(broker): refactor opentelemertry exporter by @ShadowySpirits in #842
- fix(kafka_issues581): fix over capacity deadlock by @superhx in #843
- feat(proxy): add metrics and trace for remoting send and pull RPC by @ShadowySpirits in #844
- refactor(s3stream): show advices in error msg by @mooc9988 in #841
- feat(s3stream): add more metrics by @SCNieh in #845
- fix(ci): temporarily disable the remoting e2e test. by @ShadowySpirits in #846
- feat(s3stream): add metrics for read ahead latency and r/w queued time by @SCNieh in #848
- refactor(store): refactor MessageStateMachine by @ShadowySpirits in #849
- refactor(s3stream): only lock the
deltaWAL.append
by @Chillax-0v0 in #847 - feat(s3stream): set explicit boundaries for network queue time hist by @SCNieh in #852
- perf(S3Storage): speed up
forceUpload
by @Chillax-0v0 in #851 - feat(s3stream): support filter operation status by label by @SCNieh in #853
- feat(stream): implement MemoryMetadataManager by @ShadowySpirits in #854
- chore(s3stream): metrics of upload wal by @Chillax-0v0 in #856
- feat(kafka_issues601): optimize memory usage when upload too much blocks by @superhx in #857
- perf(s3storage): speedup
forceUpload
during shutdown by @Chillax-0v0 in #858 - feat(stream): add stream range continuous check for MemoryMetadataManager by @ShadowySpirits in #860
- fix(s3stream): fix infinite loop in s3 check by @ShadowySpirits in #862
- feat(s3stream): make AbstractOrderedCollection could be extented by others by @superhx in #863
- test(s3stream/util): test
FutureTicker
by @Chillax-0v0 in #859 - feat(s3stream): introduce tracing to s3stream by @SCNieh in #866
- perf(s3stream):
thenAcceptAsync
without executor ->thenAccept
by @Chillax-0v0 in #867 - refactor(s3stream): standardize the code style by @ShadowySpirits in #864
- chore(s3stream): update the version not updated in commit f4e37d1 by @Chillax-0v0 in #868
- feat(s3stream): reuse attributes to reduce cost during recording metrics by @SCNieh in #869
- test(s3stream/util): fix tests by @Chillax-0v0 in #865
- feat(s3stream): support record metrics by level for s3stream by @SCNieh in #870
- refactor(stream): format and cleanup code by @ShadowySpirits in #874
- feat(s3stream): change read ahead size metrics level to INFO by @SCNieh in #871
- fix(s3stream/wal): fix checks before
scaleOutWindow
by @Chillax-0v0 in #873 - refactor(stream): make CompactionManager#compact public by @ShadowySpirits in #877
- ci(stream): add e2e ci by @ShadowySpirits in #878
- fix(stream): use getBucketACL instead of headBucket to check if bucket exist by @ShadowySpirits in #879
- feat(s3stream): remove the logic that checks if the bucket exists by @ShadowySpirits in #880
- feat(s3stream): wait for the background executor to close when shutting down the S3 storage by @ShadowySpirits in #876
- feat(kafka_issues618): stream object compact support drop expired data by @superhx in #881
- feat(s3stream): copy write based on max part size by @superhx in #883
- perf(s3stream): use read lock rather than write lock in append by @Chillax-0v0 in #886
- fix(s3Stream): remove list-bucket checking by @mooc9988 in #885
- feat(kafka_issues642): object format support data block group by @superhx in #887
- feat(s3stream): optimize metrics performance by @SCNieh in #889
- feat(kafka_issues642): stream object compact group small data blocks by @superhx in #890
- feat(s3stream): merge small data blocks during compaction by @SCNieh in #891
- fix(s3stream): fix operation latency unit by @SCNieh in #892
- perf(s3stream): use
for
loop rather thanstream
in critical paths by @Chillax-0v0 in #894 - chore: optimize S3Utils output by @KaimingWan in #895
- fix(s3stream): delete out-dated object directly during compaction by @SCNieh in #896
- feat(s3stream): atomic failover feature by @superhx in #899
- refactor(s3stream): create
S3Operator
with credential providers by @Chillax-0v0 in #898 - chore: add gradle build system for s3stream by @daniel-y in #900
New Contributors
- @KaimingWan made their first contribution in #895
Full Changelog: v0.1.0-beta...v0.1.1-beta