apache/pulsar-client-go

View on GitHub

Apache Pulsar Go Client Library

Stars: 745
Forks: 389
Open beginner issues: 0
Indexed issues: 203
Avg merge: 3d 20h
Merged PRs (30d): 3

Dominant language: Go
License: Apache-2.0
Last GitHub push: Aug 26, 2026
Latest indexed: Sep 14, 2026
Contributing guide: Contributing guide
Code of conduct: Code of conduct
Beginner labels: help wanted

Open All

203 open issues indexed

[Question] Semantics behind MaxDeliveries property Open

apache/pulsar-client-go#501 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
topic parse error should be checked Open

apache/pulsar-client-go#506 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
feature: zero queue Open

apache/pulsar-client-go#511 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Unsubscribe from 1..n topic(s) in multi-topic/regexp subscription Open

apache/pulsar-client-go#512 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Producer Send and SendAsyn is blocked for forever when pulsar is down Open

apache/pulsar-client-go#515 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Connection health checks Open

apache/pulsar-client-go#519 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Justification for accepting PR #524 for 0.6.0 when #481 (updating jwt-go version) was already included in 0.5.0? Open

apache/pulsar-client-go#531 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
zstd library problem Open

apache/pulsar-client-go#537 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
short read when reading frame size Open

apache/pulsar-client-go#538 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
go client producer + schema breaks Pulsar SQL Open

apache/pulsar-client-go#546 · 7 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
panic: connection error Open

apache/pulsar-client-go#547 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Reader] The topic not found when create reader with listener name Open

apache/pulsar-client-go#553 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Windows user can't build this lib Open

apache/pulsar-client-go#573 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Failed to get last message id when reader try to read from last message id Open

apache/pulsar-client-go#577 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Reader can not read next coming messages when start with LatestMessageID Open

apache/pulsar-client-go#583 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
connection should fail all pending requests when occurs ServerError_TopicTerminatedError Open

apache/pulsar-client-go#587 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
consume stuck after seekByTiime Open

apache/pulsar-client-go#593 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Ack batch msgs Open

apache/pulsar-client-go#597 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Is there no org.apache.pulsar.client.impl.auth.AuthenticationBasic authentication method provided? Open

apache/pulsar-client-go#602 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Reader.Next(ctx) redelivers a same message after reconnecting to broker Open

apache/pulsar-client-go#605 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
client keeps using an already closed producer Open

apache/pulsar-client-go#606 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Release oauth2 with new Tags Open

apache/pulsar-client-go#609 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
please check Failed by consumer Ack Message ID Open

apache/pulsar-client-go#628 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] The pendingRequest resource may leak Open

apache/pulsar-client-go#636 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
when grabCnx/grabConn throw error while create client ,And client will be failure to bean created. but it is not neccessary. and this handle-way is different with java client Open

apache/pulsar-client-go#640 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
when lookup get error Response without AuthorizationError. client should can be retry to create consumer or producer instead of throw error out only Open

apache/pulsar-client-go#642 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Apache Pulsar support in ArgoLabs Dataflow Open

apache/pulsar-client-go#643 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Consumer need to support commulated ack type to reducer 'acknowledgment holes' Open

apache/pulsar-client-go#657 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Some partition topics' consumer stop consuming news while other partition's consumer of this topic is reconnecting Open

apache/pulsar-client-go#659 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
ReconsumeLater cause panic Open

apache/pulsar-client-go#664 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
When client received ServerError_ChecksumError ,we need resend message without close connection immediately! Open

apache/pulsar-client-go#666 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
High cpu pres Open

apache/pulsar-client-go#668 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add unit test case for SubscriptionProperties Open

apache/pulsar-client-go#672 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[BUG] When reconnecting to the server, the old connection is not closed Open

apache/pulsar-client-go#676 · 15 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Pulsar sql EOF exception when using go client to send empty payload Open

apache/pulsar-client-go#680 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
DisableBatching still go thru the batching logic and AUTO_CONSUME can not consume with correct schema type Open

apache/pulsar-client-go#681 · 2 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
Add LastSequenceID interface for consumer Open

apache/pulsar-client-go#685 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Consumer can't receive messag after broker has been restarted Open

apache/pulsar-client-go#698 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add PhysicalAddr() method to interface Producer and Consumer for client-side metric report? Open

apache/pulsar-client-go#724 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Resend after reconnection cause reproduce of the same msg Open

apache/pulsar-client-go#731 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Producer can not reconnect to broker after server restart Open

apache/pulsar-client-go#733 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
`NewProtoSchema` is initialized as AvroSchema Open

apache/pulsar-client-go#739 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
prometheus not call Unregister Open

apache/pulsar-client-go#764 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[bugfix] fix stuck when ProducerBlockedQuotaExceededException Open

apache/pulsar-client-go#768 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
AckID block calling goroutine Open

apache/pulsar-client-go#770 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
aynsc send [hasSpace()] control has bad performance when send large message Open

apache/pulsar-client-go#771 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[BUG] flow controller Open

apache/pulsar-client-go#784 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[BUG] upgrade linkedin/goavro to v2.11.1 Open

apache/pulsar-client-go#786 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[help] goroutine leak Open

apache/pulsar-client-go#788 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Support transaction Open

apache/pulsar-client-go#789 · 1 comment · 5 reactions · 0 assignees · Indexed Sep 14, 2026

apache/pulsar-client-go

Get new issues in your inbox