pulsar

pulsar copied to clipboard

[improve][client]PIP-189: No batching if only one message in batch

3

email discussion thread: https://lists.apache.org/thread/dbq1lrv03bhtk0lr5nwm5txo9ndjplv0 ### Motivation * See https://github.com/apache/pulsar/issues/16619 ### Modifications * See https://github.com/apache/pulsar/issues/16619 * Most of the Modifications are relevant to `BatchMessageContainerImpl` * Of course there are some tests...

AnonHxy

java.lang.NoClassDefFoundError: org/apache/pulsar/shade/io/netty/buffer/PoolArena$1

1

When using pulsar client to send messages in flick, the following errors often appear. How can I end up java.lang.NoClassDefFoundError: org/apache/pulsar/shade/io/netty/buffer/PoolArena$1 at org.apache.pulsar.shade.io.netty.buffer.PoolArena.freeChunk(PoolArena.java:247) at org.apache.pulsar.shade.io.netty.buffer.PoolThreadCache$MemoryRegionCache.freeEntry(PoolThreadCache.java:430) at org.apache.pulsar.shade.io.netty.buffer.PoolThreadCache$MemoryRegionCache.free(PoolThreadCache.java:396) at org.apache.pulsar.shade.io.netty.buffer.PoolThreadCache$MemoryRegionCache.trim(PoolThreadCache.java:414) at...

oldwangmate

### Motivation Fix thread blocked: ``` "main" prio=0 tid=0x0 nid=0x0 waiting on condition java.lang.Thread.State: TIMED_WAITING on java.util.concurrent.CompletableFuture$Signaller@6d214cc3 at [email protected]/jdk.internal.misc.Unsafe.park(Native Method) at [email protected]/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:252) at [email protected]/java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1866) at [email protected]/java.util.concurrent.ForkJoinPool.unmanagedBlock(ForkJoinPool.java:3463) at [email protected]/java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3434) at [email protected]/java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1939)...

nodece

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Example failure https://github.com/apache/pulsar/runs/7720536583?check_suite_focus=true#step:10:1299 ### Exception stacktrace ``` java.lang.AssertionError: expected [10] but found [9] at...

RobertIndie

Fixes #16488 *(or if this PR is one task of a github issue, please add `Master Issue: #` to link to the master issue.)* Master Issue: # ### Motivation *Explain...

leizhiyuan

Flaky-test: BasicEndToEndTest.testPatternMultiTopicsConsumerPubSub

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Example failure https://github.com/apache/pulsar/runs/7739162912?check_suite_focus=true#step:11:185 ### Exception stacktrace ``` /pulsar/pulsar-client-cpp/tests/BasicEndToEndTest.cc:2184: Failure Expected equality of these values:...

tisonkun

[monitor][txn] Add metrics for transaction

19

### Motivation add metrics for transaction ### Does this pull request potentially affect one of the following parts: *If `yes` was chosen, please highlight the changes* - Dependencies (does it...

tjiuming

[Doc] wrong pip in 2.10.0 release notes

2

### What issue do you find in Pulsar docs? In `2.10.0` 's release notes: ``` [PIP 106] Broker extensions to provide operators of enterprise-wide clusters better control and flexibility [#12536](https://github.com/apache/pulsar/pull/12536)...

youzipi

### Motivation * Reduce local REST calll for `org.apache.pulsar.broker.admin.impl.PersistentTopicsBase#internalGetReplicatedSubscriptionStatus` ### Modifications * Call local method if partition is owned by this broker, or call REST api usng internal `AdminClient` ###...

AnonHxy

[refactor][client c++] Delete PartitionedConsumerImpl, use MultiTopicsConsumerImpl instead

3

### Motivation The code of the C++ client is still relatively old, after #1365, the java client used `MultiTopicConsumerImpl` instead of `PartitionedConsumerImpl`. ### Modifications - Delete PartitionedConsumerImpl, use MultiTopicsConsumerImpl instead....

shibd