paashzj/kafka_go_pulsar issues and pull requests

#203 - Bump github.com/docker/docker from 20.10.22+incompatible to 23.0.4+incompatible

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

#202 - Bump github.com/docker/docker from 20.10.22+incompatible to 23.0.3+incompatible

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

#201 - Bump github.com/docker/docker from 20.10.22+incompatible to 23.0.2+incompatible

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

#200 - Bump actions/setup-go from 3 to 4

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

#199 - Bump go.opentelemetry.io/otel/exporters/jaeger from 1.11.2 to 1.14.0

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

#198 - Bump go.opentelemetry.io/otel from 1.11.2 to 1.14.0

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

#197 - Bump go.opentelemetry.io/otel/trace from 1.11.2 to 1.14.0

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

#196 - Bump go.opentelemetry.io/otel/sdk from 1.11.2 to 1.14.0

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

#195 - Bump github.com/docker/docker from 20.10.22+incompatible to 23.0.1+incompatible

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

#194 - Bump go.opentelemetry.io/otel/trace from 1.11.2 to 1.13.0

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

#193 - Bump go.opentelemetry.io/otel/sdk from 1.11.2 to 1.13.0

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

#192 - Bump go.opentelemetry.io/otel/exporters/jaeger from 1.11.2 to 1.13.0

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

#191 - Bump go.opentelemetry.io/otel from 1.11.2 to 1.13.0

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

#190 - Bump github.com/docker/docker from 20.10.22+incompatible to 23.0.0+incompatible

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

#189 - Bump go.opentelemetry.io/otel from 1.11.2 to 1.12.0

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

#188 - Bump go.opentelemetry.io/otel/sdk from 1.11.2 to 1.12.0

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

#187 - Bump go.opentelemetry.io/otel/exporters/jaeger from 1.11.2 to 1.12.0

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

#186 - Bump go.opentelemetry.io/otel/trace from 1.11.2 to 1.12.0

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

#185 - Bump github.com/docker/docker from 20.10.22+incompatible to 20.10.23+incompatible

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

#184 - Bump github.com/docker/docker from 20.10.21+incompatible to 20.10.22+incompatible

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

#183 - support check groupId

Pull Request - State: closed - Opened by tyluffy almost 2 years ago - 1 comment

#182 - support remove offset interface

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

#181 - switch form reader to consumer when fetch partition

Pull Request - State: closed - Opened by tyluffy almost 2 years ago - 1 comment

#180 - Bump go.opentelemetry.io/otel/sdk from 1.11.1 to 1.11.2

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

#179 - Bump go.opentelemetry.io/otel/exporters/jaeger from 1.11.1 to 1.11.2

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

#178 - 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, go

#177 - 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, go

#176 - upgrade kafka codec version

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

#175 - fix kafka client err when kafka produce failed

Pull Request - State: closed - Opened by tyluffy about 2 years ago - 1 comment

#174 - Bump github.com/segmentio/kafka-go from 0.4.36 to 0.4.38

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

#173 - fix: generationId data race

Pull Request - State: closed - Opened by xuthus5 about 2 years ago - 1 comment

#172 - Bump github.com/segmentio/kafka-go from 0.4.35 to 0.4.36

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

#171 - Bump github.com/docker/docker from 20.10.20+incompatible to 20.10.21+incompatible

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

#170 - Bump github.com/stretchr/testify from 1.8.0 to 1.8.1

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

#169 - Bump go.opentelemetry.io/otel/sdk from 1.10.0 to 1.11.1

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

#168 - Bump go.opentelemetry.io/otel/trace from 1.10.0 to 1.11.1

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

#167 - Bump go.opentelemetry.io/otel from 1.10.0 to 1.11.1

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

#166 - Bump go.opentelemetry.io/otel/exporters/jaeger from 1.10.0 to 1.11.1

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

#165 - Bump github.com/docker/docker from 20.10.19+incompatible to 20.10.20+incompatible

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

#164 - Bump github.com/docker/docker from 20.10.18+incompatible to 20.10.19+incompatible

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

#163 - Bump go.opentelemetry.io/otel/trace from 1.10.0 to 1.11.0

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

#162 - Bump go.opentelemetry.io/otel/sdk from 1.10.0 to 1.11.0

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

#161 - Bump go.opentelemetry.io/otel from 1.10.0 to 1.11.0

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

#160 - Bump go.opentelemetry.io/otel/exporters/jaeger from 1.10.0 to 1.11.0

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

#159 - ignore: ack failed, continue to execute

Pull Request - State: closed - Opened by xuthus5 about 2 years ago - 1 comment

#158 - upgrade: pulsar-client-go version to 0.9.0

Pull Request - State: closed - Opened by xuthus5 about 2 years ago - 1 comment

#157 - Optimize rebalance

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

#156 - debug: print OnClosed error info

Pull Request - State: closed - Opened by xuthus5 about 2 years ago - 1 comment

#155 - fix: actively close the connection

Pull Request - State: closed - Opened by xuthus5 about 2 years ago - 1 comment

#154 - Update kafka-codec to latest

Pull Request - State: closed - Opened by goflutterjava about 2 years ago - 1 comment

#153 - 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 - 1 comment
Labels: dependencies, go

#152 - Bump github.com/docker/docker from 20.10.17+incompatible to 20.10.18+incompatible

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

#151 - fix consume failed when kafka broker restart

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

#150 - upgrade kafka-codec-go version

Pull Request - State: closed - Opened by tyluffy about 2 years ago - 1 comment

#149 - fix metadata request return err when topic is empty

Pull Request - State: closed - Opened by tyluffy about 2 years ago - 1 comment

#148 - [clean code] remove unused flag.Parse

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

#147 - return broker metadata when topic is empty

Pull Request - State: closed - Opened by pcHwang2 about 2 years ago - 1 comment

#146 - upgraded kafka-codec-go to support MetadataV0-V9 SaslHandshakeV0

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

#145 - Unsupported metadata version5

Issue - State: closed - Opened by xuthus5 about 2 years ago - 1 comment

#144 - fix: actively close the connection

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

#143 - reduce: ReactFetch memory allocation

Pull Request - State: closed - Opened by xuthus5 about 2 years ago - 1 comment

#142 - fix consume failed when broker restart

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

#141 - fix rebalance failed when member leave group

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

#140 - feat: Fetch and Produce add trace tag

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

#139 - fix: ListOffsets support version 6

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

#138 - feat: sasl auth log

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

#137 - support kafka producer

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

#136 - use pulsar codec go

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

#135 - add MaxProducerRecordSize and MaxBatchSize config

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

#134 - SyncV5Resp protocolName and Type cannot be empty

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

#133 - Max support fetch version

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

#132 - Max Support JoinGroup Version 6

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

#131 - modify produce api version

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

#130 - remove create delete topics

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

#129 - update api version

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

#128 - Put variable to struct, downgrade to 1.18

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

#127 - upgraded kafka-codec to support apiReq2 MetadataV8 decode

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

#126 - feat: trace module support skywalking and otel

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

#125 - Bump to golang1.19, fix typo

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

#124 - remove: service layer

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

#123 - simplify: the code of the network module

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

#122 - Remove unused type convert

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

#121 - fix race condition

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

#120 - fix: kafka produce return RecordErrorList

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

#119 - feat: replace service datastruct to codec datastruct

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

#118 - Fix graceful exit

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

#117 - fix race condition

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

#116 - Use codec ErrorCode

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

#115 - Use kgnet step 2

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

#114 - Use kgnet step 1

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

#113 - optimize code

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

#112 - update kafka-go

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

#111 - fix multi consumer rebalance failed

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

#110 - feat: skywalking with kafka_impl

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

#109 - Bump github.com/segmentio/kafka-go from 0.4.33 to 0.4.34

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

#108 - Bump github.com/SkyAPM/go2sky from 1.4.1 to 1.5.0

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

#107 - upgraded kafka_go

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

#106 - fix: Skywalking open stream error because empty host or port

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

#105 - upgraded kafka_go

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

#104 - reduce: when ctx exceeded, don't output log.

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

GitHub / paashzj/kafka_go_pulsar issues and pull requests