pulsar

pulsar copied to clipboard

[wip][fix][fn] Add function name and id to producer name to avoid conflict

3

Fixes #21911 Main Issue: #xyz PIP: #xyz ### Motivation there will be producer name conflicts error when function enable effectively_once and subscribed to a partitioned input topic ### Modifications Add...

jiangpengcheng

[improve][broker] Improve checking topic exists

2

### Motivation The `org.apache.pulsar.broker.admin.AdminResource#checkTopicExistsAsync` cannot correctly check the topic exists. Create a non-persistent topic with partitions 3: ```java admin.topics().createPartitionedTopic(partitionedTopicName, 3); // 1 admin.topics().createPartitionedTopic(partitionedTopicName, 3); // 2 ``` See the following...

nodece

### Motivation The `ack` command will fail when the consumer is reconnecting when setting `acknowledgmentGroupTime ->0`. see https://github.com/apache/pulsar/blob/master/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java#L361-L364 ```java private CompletableFuture doImmediateAck(MessageIdAdv msgId, AckType ackType, Map properties, BitSetRecyclable bitSet) {...

poorbarcode

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation Currently, Pulsar does not monitor the number of connections to client IPs and...

yyj8

Flaky-test: ProducerConsumerInternalTest.testExclusiveConsumerWillAlwaysRetryEvenIfReceivedConsumerBusyError

5

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Example failures - [2023-11-01T23:47:34.3601084Z](https://github.com/apache/pulsar/actions/runs/6726225527/job/18282371976#step:10:1551) - [2023-10-30T14:02:56.8701471Z](https://github.com/apache/pulsar/actions/runs/6693353223/job/18185623275#step:10:1551) ### Exception stacktrace ``` org.awaitility.core.ConditionTimeoutException: Assertion condition defined...

lhotari

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### What issue do you find in Pulsar docs? The link says that the default...

qiyingqizi

### Motivation Simplify the label name and change the default doc template label from `doc-required` to `doc` ### Documentation - [ ] `doc` - [ ] `doc-required` - [x] `doc-not-needed`...

Technoboy-

Main Issue: #21631 ### Motivation ### Modifications - Add warn log when can't add message to the container. ### Documentation - [ ] `doc` - [ ] `doc-required` - [x]...

Technoboy-

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### What issue do you find in Pulsar docs? This part is confusing: > The...

lhotari

[fix][client] Producer uses pulsar-client-internal thread to execute callback

2

Fixes #21900 ### Motivation In #21900, I guess the user uses a sync call in the `pulsar-client-io` callback thread, so throw the timeout exception. The `pulsar-client-io` thread is used to...

nodece