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 14h
Merged PRs (30d): 160

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

1253 open issues indexed

make internalSetMaxConsumersPerSubscription async Open

Stale type/bug

apache/pulsar#15856 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
PIP-172 : Introduce the `HEALTH_CHECK` command in the binary protocol Open

Stale type/PIP

apache/pulsar#15859 · 14 comments · 3 reactions · 1 assignee · Indexed Sep 14, 2026
metadata-store thread should not execute onPoliciesUpdate synchronized when PoliciesUpdate Open

Stale type/bug

apache/pulsar#15861 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Inactive topic cleaning up does not work properly Open

Stale type/bug

apache/pulsar#15881 · 7 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Discuss] Pulsar client : Connect Command add `keep_alive_interval` Open

Stale

apache/pulsar#15885 · 10 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Flaky-test: RackAwareTest.testRackUpdate Open

area/test Stale type/flaky-tests

apache/pulsar#15895 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
KeyShared consumers with sticky hash range generate backlog with messages not fall within consumer hash range - v2.9.2 Open

Stale type/bug

apache/pulsar#15898 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
msgbacklog is not accurate between shutdowns Open

Stale type/bug

apache/pulsar#15948 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
PIP-174: Provide new implementation for broker dispatch cache Open

Stale type/PIP

apache/pulsar#15954 · 2 comments · 1 reaction · 1 assignee · Indexed Sep 14, 2026
initialize pulsar cluster metadata failed, can;t recognize ipv6 ip and port Open

Stale type/bug

apache/pulsar#15960 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[AutoRecovery] keep rereplicate a ledger which is deleted Open

Stale type/bug

apache/pulsar#15992 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[bug][java-client] Client creation fails with enableTransactions=true if topic transaction_coordinator_assign has not been created yet Open

area/transaction Stale type/bug

apache/pulsar#15996 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] NPE of StringSchema for branch-2.10 Open

area/test Stale

apache/pulsar#16000 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
When using the Python pulsar client, crashes occasionally happen on connect/disconnect/close due to pthread_mutex_lock assertion failures Open

Stale type/bug

apache/pulsar#16009 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Pulsar Standalone Docker image does not work. Open

Stale type/bug

apache/pulsar#16013 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
FlinkPulsarSink EXACTLY_ONCE issue Open

Stale type/bug

apache/pulsar#16037 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
when ServerCnx has no consumers and producers, recycle the connection Open

Stale type/feature

apache/pulsar#16050 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[pulsar admin] Add commands to run 'scanOffloadedLedgers' Open

Stale type/feature

apache/pulsar#16070 · 1 comment · 1 reaction · 1 assignee · Indexed Sep 14, 2026
stackoverflow when many unacked messages or delay messages Open

Stale type/bug

apache/pulsar#16074 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Doc] Improve pulsar-perf transaction example Open

area/cli area/transaction doc-required Stale

apache/pulsar#16089 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Why Roles do not support concurrent authorization？ Open

type/feature

apache/pulsar#16105 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
inconsistent behavior in ttl strategy Open

Stale

apache/pulsar#16114 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
brokerClientAuthenticationPlugin param doesn't restore to default after deletion dynamic config value Open

Stale type/bug

apache/pulsar#16123 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Functions] Upload nar file to start function task failed Open

Stale type/bug

apache/pulsar#16132 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[BUG] ThresholdShedder Bundles Inaccurate traffic statistics Open

Stale type/bug

apache/pulsar#16145 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
support retry strategy when produce message Open

Stale type/feature

apache/pulsar#16151 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
PIP-180: Shadow Topic, an alternative way to support readonly topic ownership. Open

Stale type/PIP

apache/pulsar#16153 · 5 comments · 6 reactions · 1 assignee · Indexed Sep 14, 2026
load liborg_apache_pulsar_shade_netty_transport_native_epoll_x86_64 error Open

Stale type/bug

apache/pulsar#16158 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Error when get a non-persist topic info which is not initialized with jwt token Open

Stale type/bug

apache/pulsar#16169 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
AWS Deployment using terraform | all nodes have SSH open to the world Open

Stale

apache/pulsar#16176 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Unauthorized; error code: 401 when using pulsar-io-kafka connector with schema-registry that requires auth Open

Stale

apache/pulsar#16181 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[topic][HTTP500 Internal Server Error] unexpected error when trying to delete partitioned-topic with admin-cli Open

Stale type/bug

apache/pulsar#16188 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Problems with Reader mode Open

Stale type/feature

apache/pulsar#16210 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Pulsar Admin API client should support retries on operations Open

apache/pulsar#16249 · 9 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
PIP-182: Provide new load balance placement strategy implementation for ModularLoadManagerStrategy Open

Stale type/PIP

apache/pulsar#16274 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
geo-replication AuthenticationException: Unable to authenticate Open

Stale

apache/pulsar#16280 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
s3ManagedLedgerOffloadReadBufferSizeInBytes not work when set in broker Open

Stale type/bug

apache/pulsar#16294 · 25 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Discuss: Make hasMessageAvailable to interface Consumer. Open

Stale type/bug

apache/pulsar#16358 · 4 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
Flaky-test: PackagesApiNotEnabledTest.testPackagesOperationsWithoutPackagesServiceEnabled Open

area/test Stale type/flaky-tests

apache/pulsar#16376 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
the bookie heap used not balance after run a while and cause one bookie OOM. Open

Stale type/bug

apache/pulsar#16387 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Incorrect detection of NAR files Open

Stale type/bug

apache/pulsar#16397 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
PIP-183: Reduce unnecessary REST call in broker Open

Stale type/PIP

apache/pulsar#16422 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
PIP-136: Sync Pulsar policies across multiple clouds Open

Stale type/PIP

apache/pulsar#16424 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
ZKMetadataStore: BadVersion for /ledgers/underreplication/LAYOUT Open

Stale type/bug

apache/pulsar#16455 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Flaky-test: org.apache.pulsar.client.impl.schema.SchemaInfoTest.testSchemaInfoToString Open

area/test Stale type/flaky-tests

apache/pulsar#16458 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Duplication of data occurs when send from device to pulsar with messageid different but timestamp exactly same upto millisec Open

Stale

apache/pulsar#16469 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Golang pulsar function can not subscribe to topic using regex Open

Stale type/bug

apache/pulsar#16478 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Pulsar 2.9.2: messages are in backlog, but not dispatched to consumers Open

Stale type/bug

apache/pulsar#16511 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Flaky-test: BrokerServiceTest.testLookupThrottlingForClientByClient Open

area/test type/flaky-tests

apache/pulsar#16521 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
PIP-186: Introduce two phase deletion protocol based on system topic Open

Stale type/PIP

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

apache/pulsar

Get new issues in your inbox