Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / automq/automq-for-rocketmq issues and pull requests

#905 - refactor: avoid use jdk api upper jdk11

Pull Request - State: open - Opened by lifepuzzlefun1 12 months ago - 2 comments

#904 - fix: avoid use jdk api upper jdk11

Pull Request - State: closed - Opened by lifepuzzlefun 12 months ago - 1 comment

#903 - perf(s3stream): Optimize StreamRecordBatchList

Pull Request - State: open - Opened by lifepuzzlefun 12 months ago - 2 comments

#902 - chore: intrdouce spotbugs for s3stream, and reslove all the P1 issues

Pull Request - State: closed - Opened by daniel-y 12 months ago - 1 comment

#901 - refactor: downgrade the source level of s3stream to java11

Pull Request - State: closed - Opened by daniel-y almost 1 year ago - 1 comment

#900 - chore: add gradle build system for s3stream

Pull Request - State: closed - Opened by daniel-y almost 1 year ago

#899 - feat(s3stream): atomic failover feature

Pull Request - State: closed - Opened by superhx about 1 year ago - 1 comment

#898 - refactor(s3stream): create `S3Operator` with credential providers

Pull Request - State: closed - Opened by Chillax-0v0 about 1 year ago - 2 comments

#897 - Delete out-dated S3 object during compaction

Issue - State: open - Opened by SCNieh about 1 year ago
Labels: enhancement

#896 - fix(s3stream): delete out-dated object directly during compaction

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 2 comments

#895 - chore: optimize S3Utils output

Pull Request - State: closed - Opened by KaimingWan about 1 year ago - 1 comment

#894 - perf(s3stream): use `for` loop rather than `stream` in critical paths

Pull Request - State: closed - Opened by Chillax-0v0 about 1 year ago - 1 comment

#893 - chore: optimize S3Utils output

Pull Request - State: closed - Opened by KaimingWan about 1 year ago - 2 comments

#892 - fix(s3stream): fix operation latency unit

Pull Request - State: closed - Opened by SCNieh about 1 year ago

#891 - feat(s3stream): merge small data blocks during compaction

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#890 - feat(kafka_issues642): stream object compact group small data blocks

Pull Request - State: closed - Opened by superhx about 1 year ago - 1 comment

#889 - feat(s3stream): optimize metrics performance

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#888 - S3Stream metrics support topic label

Issue - State: open - Opened by SCNieh about 1 year ago

#887 - feat(kafka_issues642): object format support data block group

Pull Request - State: closed - Opened by superhx about 1 year ago - 1 comment

#886 - perf(s3stream): use read lock rather than write lock in append

Pull Request - State: closed - Opened by Chillax-0v0 about 1 year ago - 1 comment
Labels: enhancement

#885 - fix(s3Stream): remove list-bucket checking

Pull Request - State: closed - Opened by mooc9988 about 1 year ago - 1 comment

#884 - remove list-bucket checking in S3Utils#checkS3Access

Issue - State: closed - Opened by mooc9988 about 1 year ago

#883 - feat(s3stream): copy write based on max part size

Pull Request - State: closed - Opened by superhx about 1 year ago - 1 comment

#882 - install_flatc.sh not support MacOS

Issue - State: open - Opened by KaimingWan about 1 year ago

#881 - feat(kafka_issues618): stream object compact support drop expired data

Pull Request - State: closed - Opened by superhx about 1 year ago - 1 comment

#880 - feat(s3stream): remove the logic that checks if the bucket exists

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#879 - fix(stream): use getBucketACL instead of headBucket to check if bucket exist

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#878 - ci(stream): add e2e ci

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#877 - refactor(stream): make CompactionManager#compact public

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#875 - feat(groupStatus): Add "groupStatus" command to the CLI tools #764

Pull Request - State: open - Opened by zhouyou9505 about 1 year ago - 1 comment

#874 - refactor(stream): format and cleanup code

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#873 - fix(s3stream/wal): fix checks before `scaleOutWindow`

Pull Request - State: closed - Opened by Chillax-0v0 about 1 year ago - 1 comment

#872 - Bug: The append operation of S3Stream may block indefinitely

Issue - State: closed - Opened by ShadowySpirits about 1 year ago
Labels: bug, s3stream

#871 - feat(s3stream): change read ahead size metrics level to INFO

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#870 - feat(s3stream): support record metrics by level for s3stream

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#869 - feat(s3stream): reuse attributes to reduce cost during recording metrics

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#867 - perf(s3stream): `thenAcceptAsync` without executor -> `thenAccept`

Pull Request - State: closed - Opened by Chillax-0v0 about 1 year ago

#866 - feat(s3stream): introduce tracing to s3stream

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#865 - test(s3stream/util): fix tests

Pull Request - State: closed - Opened by Chillax-0v0 about 1 year ago - 1 comment

#864 - refactor(s3stream): standardize the code style

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#863 - feat(s3stream): make AbstractOrderedCollection could be extented by others

Pull Request - State: closed - Opened by superhx about 1 year ago - 1 comment

#862 - fix(s3stream): fix infinite loop in s3 check

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#861 - Infinite loop in s3 check

Issue - State: closed - Opened by ShadowySpirits about 1 year ago

#860 - feat(stream): add stream range continuous check for MemoryMetadataManager

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#859 - test(s3stream/util): test `FutureTicker`

Pull Request - State: closed - Opened by Chillax-0v0 about 1 year ago - 1 comment

#858 - perf(s3storage): speedup `forceUpload` during shutdown

Pull Request - State: closed - Opened by Chillax-0v0 about 1 year ago - 2 comments
Labels: enhancement

#857 - feat(kafka_issues601): optimize memory usage when upload too much blocks

Pull Request - State: closed - Opened by superhx about 1 year ago - 1 comment

#856 - chore(s3stream): metrics of upload wal

Pull Request - State: closed - Opened by Chillax-0v0 about 1 year ago - 1 comment

#855 - The frequent use of append with small sizes can consume excessive memory

Issue - State: open - Opened by Chillax-0v0 about 1 year ago - 3 comments
Labels: enhancement

#854 - feat(stream): implement MemoryMetadataManager

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 2 comments

#853 - feat(s3stream): support filter operation status by label

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#852 - feat(s3stream): set explicit boundaries for network queue time hist

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#851 - perf(S3Storage): speed up `forceUpload`

Pull Request - State: closed - Opened by Chillax-0v0 about 1 year ago - 1 comment
Labels: enhancement, s3stream

#850 - Closing streams cost a lot during shutdown

Issue - State: closed - Opened by Chillax-0v0 about 1 year ago - 1 comment
Labels: enhancement, s3stream

#849 - refactor(store): refactor MessageStateMachine

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#848 - feat(s3stream): add metrics for read ahead latency and r/w queued time

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#847 - refactor(s3stream): only lock the `deltaWAL.append`

Pull Request - State: closed - Opened by Chillax-0v0 about 1 year ago - 1 comment

#846 - fix(ci): temporarily disable the remoting e2e test.

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#845 - feat(s3stream): add more metrics

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#844 - feat(proxy): add metrics and trace for remoting send and pull RPC

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#843 - fix(kafka_issues581): fix over capacity deadlock

Pull Request - State: closed - Opened by superhx about 1 year ago - 1 comment

#842 - refactor(broker): refactor opentelemertry exporter

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#841 - refactor(s3stream): show advices in error msg

Pull Request - State: closed - Opened by mooc9988 about 1 year ago - 1 comment

#840 - feat(s3stream): show s3 configure in DefaultS3Operator; add S3Utils

Pull Request - State: closed - Opened by mooc9988 about 1 year ago - 2 comments

#839 - fix(s3stream): find in data block with real record size

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#838 - fix(kafka_issues562): fix duplicated release

Pull Request - State: closed - Opened by superhx about 1 year ago - 1 comment

#837 - fix(s3stream): fix sanity check when stream is trimmed in the middle

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#836 - fix(s3stream): catch storage callback exception

Pull Request - State: closed - Opened by superhx about 1 year ago - 1 comment

#835 - feat(s3stream): add read block cache context to trace status

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#834 - feat(s3stream): add strict check mode

Pull Request - State: closed - Opened by superhx about 1 year ago - 1 comment

#833 - fix(kafka_issues563): check record continuous

Pull Request - State: closed - Opened by superhx about 1 year ago - 1 comment

#832 - build(s3stream): downgrade OT version to java8

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#831 - Reduce heap usage for small record

Issue - State: open - Opened by SCNieh about 1 year ago
Labels: enhancement

#830 - fix(s3stream): remove future before complete it to prevent infinite r…

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#829 - fix(s3stream): add missing inflight read key on async read ahead

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#827 - fix(proxy): fix getObjects interface

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#826 - fix(s3stream): fix potential incomplete future in StreamReader

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#825 - fix(controller): fix listStreamObjects interface

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#824 - refactor(s3stream): more complex magic code in data blocks

Pull Request - State: closed - Opened by Chillax-0v0 about 1 year ago
Labels: s3stream

#823 - perf(s3stream): not use byte arrays to reduce heap mem alloc when decoding

Pull Request - State: closed - Opened by Chillax-0v0 about 1 year ago - 1 comment
Labels: enhancement, s3stream

#822 - fix(broker): fix MetricsExporter shutdown logic

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago

#821 - feat(proxy): optimize forward message to another node

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#820 - fix(kafka_issues529): trim index block

Pull Request - State: closed - Opened by superhx about 1 year ago - 1 comment

#819 - feat(s3stream): implement s3stream metrics with Opentelemetry

Pull Request - State: closed - Opened by SCNieh about 1 year ago - 1 comment

#818 - feat(controller): reassign topic

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#817 - feat(distribution): broker in docker will print log into console

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#816 - fix(s3stream): bugfix on fetch data block indices of StreamReader

Pull Request - State: closed - Opened by SCNieh about 1 year ago

#814 - consumer can not consume

Issue - State: closed - Opened by mooc9988 about 1 year ago - 1 comment

#813 - test(proxy): add unit test for ProxyService

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#812 - refactor(proxy): proxy message to the node assigned to its queue

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#811 - refactor(proxy): refactor DeadLetterService

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#810 - feat(proxy): add relay rpc

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment

#809 - feat(s3stream): smooth upload wal

Pull Request - State: closed - Opened by superhx about 1 year ago - 1 comment

#808 - fix(s3stream/wal): check whether the file system supports direct IO

Pull Request - State: closed - Opened by Chillax-0v0 about 1 year ago - 2 comments
Labels: bug, s3stream, wal

#807 - feat(cli): add ConsumerClientConnection command

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 2 comments

#806 - feat(cli): add ProducerClientConnection command

Pull Request - State: closed - Opened by ShadowySpirits about 1 year ago - 1 comment