pulsar

pulsar copied to clipboard

[improve][broker] Replace all ConcurrentOpenHashMap with the official ConcurrentHashMap in JDK

2

### Motivation See https://github.com/apache/pulsar/issues/23215 ### Modifications For broker related modules, including `pulsar-broker`, `pulsar-websocket`, `managed-ledger`, - Replace all `ConcurrentOpenHashMap` with `ConcurrentHashMap` - Replace all `ConcurrentOpenHashSet` fields with `ConcurrentHashMap` - Replace unnecessary...

BewareMyPower

Flaky-test: CurrentLedgerRolloverIfFullTest.testCurrentLedgerRolloverIfFull

3

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Example failures - [2024-08-10T12:23:45.3718712Z](https://github.com/apache/pulsar/actions/runs/10331453867/job/28601771685#step:11:664) ### Exception stacktrace ``` java.lang.AssertionError: expected [5] but found [6]...

lhotari

[improve][pip] PIP-372: Allow consumers to terminally NACK a message, bypassing retries and routing directly to the DLQ

8

[PIP: 372](https://github.com/jcass8695/pulsar/blob/add/pip-367/pip/pip-372.md) ### Motivation If a consumer consumes a message and fails during the processing of that message in a terminal way, we as the client in certain scenarios may...

jcass8695

[feat] Add topic stats and metrics for observing message replay behavior and Key_Shared filtering/blocking behavior

2

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation Currently, it's very challenging to investigate issues related to message replay ("message redelivery...

lhotari

[improve][ml] Support Bookkeeper batch read

1

### Motivation In [BP-62](https://github.com/apache/bookkeeper/pull/4051), Bookkeeper starting to support batch read API, the PR is to support Bookkeeper batch reading on the Pulsar side. ### Modifications 1. Support Bookkeeper batch read...

dao-jun

[Bug] Subscription consumption stuck on consumer reconnect

9

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version Pulsar broker: 2.8.4 Java Pulsar client: 2.8.4 ### Minimal reproduce step Non-partitioned topic....

ghost

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Read release policy - [X] I understand that unsupported versions don't get bug fixes....

BewareMyPower

[PIP-264](https://github.com/apache/pulsar/blob/master/pip/pip-264.md) ### Motivation Adds authentication and token metrics, as currently described [here](https://pulsar.apache.org/docs/next/reference-metrics/#authentication-metrics), to the OpenTelemetry pipeline. ### Modifications - Adds the metrics described in https://github.com/apache/pulsar-site/pull/937 to the collector runs. These...

dragosvictor

[fix][io] Upgrade Debezium connector version to 2.6.1.Final

4

Fixes #22626 ### Motivation To Upgrade debezium version to 2.6.1.Final for all source connectors. It will address [this comment](https://github.com/apache/pulsar/pull/22813#discussion_r1634194181) as well. ### Modifications Upgraded debezium version from 1.9.7.Final to 2.6.1.Final...

mukesh154

[Bug] Pattern matching(Two Level Hierarchy) with consumer getting error while topic creation for the first time

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Read release policy - [X] I understand that unsupported versions don't get bug fixes....

Anandharajr