chenquan/go-queue issues and pull requests

#100 - feat(kafka): kafka supports authentication

Pull Request - State: closed - Opened by chenquan over 1 year ago

#99 - chore(deps): bump github.com/segmentio/kafka-go from 0.4.39 to 0.4.40

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#98 - chore(deps): bump go.opentelemetry.io/otel from 1.14.0 to 1.15.1

Pull Request - State: open - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#97 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.14.0 to 1.15.1

Pull Request - State: open - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#96 - chore(deps): bump go.opentelemetry.io/otel from 1.14.0 to 1.15.0

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago - 1 comment
Labels: dependencies

#95 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.14.0 to 1.15.0

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago - 1 comment
Labels: dependencies

#94 - chore: upgrade go version

Pull Request - State: closed - Opened by chenquan over 1 year ago

#93 - chore(deps): bump github.com/zeromicro/go-zero from 1.5.1 to 1.5.2

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#92 - chore(deps): bump github.com/zeromicro/go-zero from 1.4.5 to 1.5.1

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#91 - chore(deps): bump github.com/apache/pulsar-client-go from 0.9.0 to 0.10.0

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#90 - chore(deps): upgrade go zero 1.4.5 version

Pull Request - State: closed - Opened by chenquan over 1 year ago

#89 - feat(kafka): support for recovery in panic

Pull Request - State: closed - Opened by chenquan over 1 year ago

#88 - chore(deps): bump github.com/zeromicro/go-zero from 1.4.4 to 1.5.0

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago - 1 comment
Labels: dependencies

#87 - chore(deps): upgrade orderhash version

Pull Request - State: closed - Opened by chenquan over 1 year ago

#86 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.13.0 to 1.14.0

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#85 - chore(deps): bump go.opentelemetry.io/otel from 1.13.0 to 1.14.0

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago - 1 comment
Labels: dependencies

#84 - chore: add actions

Pull Request - State: closed - Opened by chenquan over 1 year ago

#83 - chore(deps): bump go.opentelemetry.io/otel from 1.12.0 to 1.14.0

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#82 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.12.0 to 1.14.0

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#81 - chore(deps): bump github.com/segmentio/kafka-go from 0.4.38 to 0.4.39

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#80 - chore(deps): bump go.opentelemetry.io/otel from 1.12.0 to 1.13.0

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago - 1 comment
Labels: dependencies

#79 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.12.0 to 1.13.0

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago - 1 comment
Labels: dependencies

#78 - chore(deps): bump go.opentelemetry.io/otel from 1.11.1 to 1.12.0

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#77 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.11.1 to 1.12.0

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#76 - chore(deps): bump github.com/zeromicro/go-zero from 1.4.3 to 1.4.4

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#75 - chore(deps): bump github.com/chenquan/orderhash from 0.2.1 to 0.3.0

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago
Labels: dependencies

#74 - chore(deps): bump github.com/zeromicro/go-zero from 1.4.2 to 1.4.3

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago
Labels: dependencies

#73 - chore(deps): bump github.com/beanstalkd/go-beanstalk from 0.1.0 to 0.2.0

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago
Labels: dependencies

#72 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.11.1 to 1.11.2

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago - 1 comment
Labels: dependencies

#71 - chore(deps): bump go.opentelemetry.io/otel from 1.11.1 to 1.11.2

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago - 1 comment
Labels: dependencies

#70 - chore(deps): bump github.com/cespare/xxhash/v2 from 2.1.2 to 2.2.0

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago
Labels: dependencies

#69 - chore(deps): bump github.com/segmentio/kafka-go from 0.4.36 to 0.4.38

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago
Labels: dependencies

#68 - chore(deps): bump github.com/segmentio/kafka-go from 0.4.35 to 0.4.36

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago
Labels: dependencies

#67 - chore(deps): bump github.com/zeromicro/go-zero from 1.4.1 to 1.4.2

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago
Labels: dependencies

#66 - chore(deps): bump go.opentelemetry.io/otel from 1.10.0 to 1.11.1

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago
Labels: dependencies

#65 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.10.0 to 1.11.1

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago
Labels: dependencies

#64 - chore(deps): bump go.opentelemetry.io/otel from 1.10.0 to 1.11.0

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago - 1 comment
Labels: dependencies

#63 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.10.0 to 1.11.0

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago - 1 comment
Labels: dependencies

#62 - chore(deps): bump github.com/apache/pulsar-client-go from 0.8.1 to 0.9.0

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago
Labels: dependencies

#61 - feat(kafka): supports setting the interval and chunk size for asynchr…

Pull Request - State: closed - Opened by chenquan almost 2 years ago

#60 - chore(deps): bump github.com/zeromicro/go-zero from 1.4.0 to 1.4.1

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago
Labels: dependencies

#59 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.9.0 to 1.10.0

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago
Labels: dependencies

#58 - chore(deps): bump go.opentelemetry.io/otel from 1.9.0 to 1.10.0

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago
Labels: dependencies

#57 - chore(deps): bump github.com/segmentio/kafka-go from 0.4.34 to 0.4.35

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago
Labels: dependencies

#56 - chore(deps): bump github.com/segmentio/kafka-go from 0.4.33 to 0.4.34

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago
Labels: dependencies

#55 - feat(kafka): cross-system link tracking

Pull Request - State: closed - Opened by chenquan about 2 years ago

#54 - chore(deps): bump github.com/zeromicro/go-zero from 1.3.5 to 1.4.0

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago
Labels: dependencies

#53 - feat(kafka): async send

Pull Request - State: closed - Opened by chenquan about 2 years ago

#52 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.8.0 to 1.9.0

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago
Labels: dependencies

#51 - chore(deps): bump go.opentelemetry.io/otel from 1.8.0 to 1.9.0

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago
Labels: dependencies

#50 - feat(kafka): add stat in pusher

Pull Request - State: closed - Opened by chenquan about 2 years ago

#49 - chore: upgrade orderhash version

Pull Request - State: closed - Opened by chenquan about 2 years ago

#48 - chore(deps): bump github.com/segmentio/kafka-go from 0.4.32 to 0.4.33

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago - 2 comments
Labels: dependencies

#47 - chore: upgrade orderhash version

Pull Request - State: closed - Opened by chenquan about 2 years ago

#46 - perf(kafka): improve kafka consumer performance

Pull Request - State: closed - Opened by chenquan about 2 years ago

#45 - fix(kafka): fix trace

Pull Request - State: closed - Opened by chenquan about 2 years ago

#44 - feat(kafka): remove sync

Pull Request - State: closed - Opened by chenquan about 2 years ago

#43 - feat(kafka): add requiredAcks

Pull Request - State: closed - Opened by chenquan about 2 years ago

#42 - feat(kafka): add batchSize and batchBytes

Pull Request - State: closed - Opened by chenquan about 2 years ago

#41 - feat(kafka): add batchSize and batchBytes

Pull Request - State: closed - Opened by chenquan about 2 years ago

#40 - chore(kafka): topic are automatically created by default

Pull Request - State: closed - Opened by chenquan about 2 years ago

#39 - chore(kafka): no export headerKey

Pull Request - State: closed - Opened by chenquan about 2 years ago

#38 - fix(kafka): get header from context

Pull Request - State: closed - Opened by chenquan about 2 years ago

#37 - feat(kafka): add XXHashBalancer balancer

Pull Request - State: closed - Opened by chenquan about 2 years ago

#36 - feat(kafka): custom balancer

Pull Request - State: closed - Opened by chenquan about 2 years ago

#35 - chore(deps): bump github.com/zeromicro/go-zero from 1.3.4 to 1.3.5

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago - 1 comment
Labels: dependencies

#34 - fix(kafka): fix consumption error

Pull Request - State: closed - Opened by chenquan about 2 years ago

#33 - chore(kafka): remove invalid code

Pull Request - State: closed - Opened by chenquan about 2 years ago

#32 - chore(deps): bump go.opentelemetry.io/otel from 1.7.0 to 1.8.0

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago - 1 comment
Labels: dependencies

#31 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.7.0 to 1.8.0

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago - 1 comment
Labels: dependencies

#30 - chore(deps): bump github.com/apache/pulsar-client-go from 0.8.0 to 0.8.1

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago - 1 comment
Labels: dependencies

#29 - chore(deps): bump github.com/segmentio/kafka-go from 0.4.28 to 0.4.32

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago - 3 comments
Labels: dependencies

#28 - chore(action): add dependabot

Pull Request - State: closed - Opened by chenquan about 2 years ago

#27 - chore: reformat code

Pull Request - State: closed - Opened by chenquan about 2 years ago

#26 - chore: reformat code

Pull Request - State: closed - Opened by chenquan about 2 years ago

#25 - feat(kafka): sequential consumption

Pull Request - State: closed - Opened by chenquan about 2 years ago

#24 - feat(kafka): supports completion function

Pull Request - State: closed - Opened by chenquan about 2 years ago

#23 - chore: update README.md

Pull Request - State: closed - Opened by chenquan about 2 years ago

#22 - feat: kafka supports tracing

Pull Request - State: closed - Opened by chenquan over 2 years ago

#21 - fix: kafka async push

Pull Request - State: closed - Opened by chenquan over 2 years ago

#20 - feat: support kafka header

Pull Request - State: closed - Opened by chenquan over 2 years ago

#19 - feat: optimize code

Pull Request - State: closed - Opened by chenquan over 2 years ago

#18 - chore: upgrade go-zero version

Pull Request - State: closed - Opened by chenquan over 2 years ago

#17 - chore: upgrade go-zero version

Pull Request - State: closed - Opened by chenquan over 2 years ago

#16 - chore: upgrade go-zero version

Pull Request - State: closed - Opened by chenquan over 2 years ago

#15 - chore: update go-zero version

Pull Request - State: closed - Opened by chenquan over 2 years ago

#14 - feat: Add `WithSync()` queue.CallOptions

Pull Request - State: closed - Opened by chenquan over 2 years ago

#13 - refactor(kafka): optimize code

Pull Request - State: closed - Opened by chenquan over 2 years ago

#12 - fix(pulsar): close pulsar client

Pull Request - State: closed - Opened by chenquan over 2 years ago

#11 - fix(pulsar): close pulsar client

Pull Request - State: closed - Opened by chenquan over 2 years ago

#10 - refactor

Pull Request - State: closed - Opened by chenquan over 2 years ago

#9 - fix: fix kafka

Pull Request - State: closed - Opened by chenquan over 2 years ago

#8 - test: add tests

Pull Request - State: closed - Opened by chenquan over 2 years ago - 1 comment

#7 - doc: update example

Pull Request - State: closed - Opened by chenquan over 2 years ago

#6 - refactor: refactor beanstalkd

Pull Request - State: closed - Opened by chenquan over 2 years ago

#5 - feat: update example

Pull Request - State: closed - Opened by chenquan over 2 years ago

#4 - doc: update example

Pull Request - State: closed - Opened by chenquan over 2 years ago

#3 - feat: add pulsar

Pull Request - State: closed - Opened by chenquan over 2 years ago

#2 - chore: add workflows

Pull Request - State: closed - Opened by chenquan over 2 years ago

#1 - feat: add pulsar

Pull Request - State: closed - Opened by chenquan over 2 years ago

GitHub / chenquan/go-queue issues and pull requests