apache/pulsar

View on GitHub

Apache Pulsar - distributed pub-sub messaging system

Stars: 15.3k
Forks: 3.8k
Open beginner issues: 0
Indexed issues: 1.3k
Avg merge: 1d 22h
Merged PRs (30d): 142

Dominant language: Java
License: Apache-2.0
Last GitHub push: Sep 16, 2026
Latest indexed: Sep 14, 2026
Contributing guide: Contributing guide
Code of conduct: Code of conduct
Beginner labels: help wanted good first issue

Open All

1254 open issues indexed

Kafka Sink Connector: support non-String keys Open

good first issue help wanted type/enhancement

apache/pulsar#9848 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[java client] Cannot integrate ProducerStats with external metrics systems Open

lifecycle/stale type/bug

apache/pulsar#10100 · 1 comment · 1 reaction · 0 assignees · Indexed Sep 14, 2026
Retention to be based on number of messages Open

lifecycle/stale type/enhancement

apache/pulsar#10268 · 8 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
schema registry / pulsar-admin: Schema type BYTES is returned as Schema type NONE Open

lifecycle/stale type/bug

apache/pulsar#10271 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Functions] PulsarAdminException when getting status on function 2/3 times Open

lifecycle/stale type/bug

apache/pulsar#10291 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Functions] Unable to create/update functions and Admin operations often fail Open

lifecycle/stale type/bug

apache/pulsar#10293 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Schema prevents usage of Dead Letter Queue DLQ Open

lifecycle/stale type/bug

apache/pulsar#10377 · 7 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Consumers not receiving messages Open

lifecycle/stale

apache/pulsar#10390 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Message loss in non-persistent geo-replication at high sending throughput Open

lifecycle/stale type/bug

apache/pulsar#10406 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Pulsar schema validation: schema info should log "default": null if it was part of Avro schema Open

lifecycle/stale type/bug

apache/pulsar#10426 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Broker & Bookie] Configure Bookkeeper client & server backpressure by default Open

lifecycle/stale type/enhancement

apache/pulsar#10439 · 8 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
Topic auto creation won't create partitioned topics if client connects to discovery node. Open

lifecycle/stale type/bug

apache/pulsar#10449 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
FunctionsStatsGenerator - Failed to collect metrics Open

lifecycle/stale type/bug

apache/pulsar#10459 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
PulsarStandaloneBuilder: make it a public API Open

good first issue help wanted type/enhancement

apache/pulsar#10473 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Allow Java client to create consumer with receiverQueueSize(0) when receiving with timeout Open

lifecycle/stale type/enhancement

apache/pulsar#10479 · 8 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Reader does not return any message when configured with reading inclusive latest messageId Open

type/bug

apache/pulsar#10483 · 3 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
Add ability to seek from current position in Reader interface Open

lifecycle/stale type/enhancement

apache/pulsar#10488 · 7 comments · 2 reactions · 0 assignees · Indexed Sep 14, 2026
pulsar functions command: topics-pattern option does not work as intended? Open

lifecycle/stale type/bug

apache/pulsar#10517 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Pulsar adds the function of querying topic messages Open

lifecycle/stale type/feature

apache/pulsar#10526 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
When I want to get the parameter returned by the consumer after sending the message, there is no way to get it. Open

lifecycle/stale type/feature

apache/pulsar#10571 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
broker.conf documentation : wrong tokenSecretKey base64 inline description Open

help wanted type/bug

apache/pulsar#10584 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Topic admin operations doesn't work well for non-persistent partitioned topics Open

lifecycle/stale type/bug

apache/pulsar#10615 · 4 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Negative acknowledgement number of retries Open

lifecycle/stale type/feature

apache/pulsar#10621 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Seek fails with partitioned topics and SubscriptionInitialPosition.Earliest Open

lifecycle/stale type/bug

apache/pulsar#10630 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Race condition with Reader.seek() Open

lifecycle/stale type/bug

apache/pulsar#10671 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
pulsar-bookie and pulsar-broker CrashLoopBackOff in kubernetes Open

lifecycle/stale type/bug

apache/pulsar#10692 · 10 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
pulsar-admin should print better error message when schema is invalid Open

lifecycle/stale type/enhancement

apache/pulsar#10694 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Gets the exact number of message backlog for pulsar topic subscription Open

lifecycle/stale type/feature

apache/pulsar#10705 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Backlog quota to be based on number of messages Open

lifecycle/stale type/enhancement

apache/pulsar#10730 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Consume pulsar by WindowFunction occurs a error Open

lifecycle/stale

apache/pulsar#10736 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Pulsar websocket client still getting result ok when websocket ProducerHandler throw an error Open

lifecycle/stale type/bug

apache/pulsar#10757 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
A newly created topic metrics do not survive after broker restarts Open

lifecycle/stale type/bug

apache/pulsar#10857 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
The consumer receives the same message again after executing the acknowledge interface Open

lifecycle/stale type/bug

apache/pulsar#10890 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Docs on protobufnative and pulsar-admin schema upload Open

lifecycle/stale type/feature

apache/pulsar#10912 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Fail to get schema ledger metadata for String schema Open

lifecycle/stale type/bug

apache/pulsar#10959 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Topic metadata not removed for partitioned topics Open

lifecycle/stale type/bug

apache/pulsar#10975 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
When we get a schema of a topic by api return Connection timed out Open

lifecycle/stale type/bug

apache/pulsar#11001 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Support configuring the BatcherBuilder through a producer property Open

lifecycle/stale type/enhancement

apache/pulsar#11036 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Flaky-test: org.apache.pulsar.client.impl.schema.PrimitiveSchemaTest.allSchemasShouldSupportNull and allSchemasShouldRoundtripInput Open

apache/pulsar#11037 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Subsctiption per topic limit reached Open

lifecycle/stale type/bug

apache/pulsar#11142 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Pulsar Sql] The number of query result records of pulsar SQL is less than that sent by producer Open

lifecycle/stale type/bug

apache/pulsar#11158 · 7 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Warning log of org.apache.avro.SchemaValidationException: Unable to read schema Open

lifecycle/stale type/bug

apache/pulsar#11163 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Tiered Storage] Create offloader for every namespace Open

lifecycle/stale type/bug

apache/pulsar#11177 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Websocket decrypting the message support Open

lifecycle/stale type/enhancement

apache/pulsar#11197 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Compacted topic will lose data when original topic message expired Open

lifecycle/stale type/bug

apache/pulsar#11211 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Pulsar Handshake was not completed within timeout, closing connection Open

lifecycle/stale type/bug

apache/pulsar#11246 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Connection issue when backlog quota is exceeded - unable to consume Open

lifecycle/stale type/bug

apache/pulsar#11250 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
broker Failed to authenticate HTTP request: Invalid signature Open

lifecycle/stale type/bug

apache/pulsar#11257 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
function worker doesn't use configurationStoreServers parameter while creating function Open

lifecycle/stale type/bug

apache/pulsar#11261 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
When the bookie storage is about to reach the threshold and then returns to the normal level, the producer cannot write topic normally Open

lifecycle/stale type/bug

apache/pulsar#11271 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026

apache/pulsar

Get new issues in your inbox