pulsar
pulsar copied to clipboard
apache
Apache Pulsar - distributed pub-sub messaging system
[example failure](https://github.com/apache/pulsar/runs/7320943955?check_suite_focus=true) ``` java.lang.AssertionError: expected object to not be null at org.testng.Assert.fail(Assert.java:99) at org.testng.Assert.assertNotNull(Assert.java:942) at org.testng.Assert.assertNotNull(Assert.java:926) at org.apache.pulsar.io.PulsarSinkE2ETest.testPulsarSinkDLQ(PulsarSinkE2ETest.java:195) ```
### Motivation In the current implementation, If the lock was expired by `release` or `revalidate`, the `expireFuture` will invoke to notify the user to clean up. However, we can still...
Master Issue: https://github.com/apache/pulsar/issues/16153 ### Motivation Add ShadowReplicator. ### Modifications - Add map `PersistentTopic#shadowReplicators`, most of its management just follows `PersistentTopic#replicators` - Add class `ShadowReplicator` ### Verifying this change - [x]...
Master Issue: #16763 ### Motivation #16763 ### Modifications * Implement BucketDelayedDeliveryTrackerFactory. * Change DeliveryTrackerFactory interface to adapter BucketDelayedDeliveryTrackerFactory. * Load BucketDelayedDeliveryTracker. ### Verifying this change - [x] Make sure that...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version linux cenos pulsar version 2.10.1 ### Minimal reproduce step Configure topic level Geo...
Master Issue: #16763 ### Motivation Now, the cursor properties support overall update and modifying a single value concurrently by #17164, but `setCursorProperties` will all key-value is removed before update properties,...
Master Issue: #16763 ### Motivation #16763 ### Modifications * Implement delayed message index bucket * Implement delayed message index bucket snapshot (create/load) * Reuse and refactor InMemoryDelayedDeliveryTracker * Reuse and...
GeoReplicationTest.testTopicReplication is flaky. It fails sporadically. [example failure](https://github.com/apache/pulsar/runs/6715214224?check_suite_focus=true#step:12:15869) ``` Error: Tests run: 43, Failures: 6, Errors: 0, Skipped: 20, Time elapsed: 552.812 s
Hello, I met an error which needs help. I am looking forward someone can answer it, thank you. I create function which string like `{"runtimeFlags":"","tenant":"public","namespace":"default","name":"PublishFunction","className":"org.apache.pulsar.functions.api.examples.PublishFunction","inputs":["persistent://public/default/function-input-topic"],"customSerdeInputs":{},"topicsPattern":"","customSchemaInputs":{},"customSchemaOutputs":{},"inputSpecs":{"persistent://public/default/function-input-topic":{"schemaType":"","serdeClassName":"","schemaProperties":{},"consumerProperties":{},"receiverQueueSize":0,"cryptoConfig":{},"poolMessages":true,"regexPattern":true}},"output":"persistent://public/default/function-output-topic","producerConfig":{"maxPendingMessages":0,"maxPendingMessagesAcrossPartitions":0,"useThreadLocalProducers":true,"cryptoConfig":{},"batchBuilder":""},"outputSchemaType":"","outputSerdeClassName":"","logTopic":"","processingGuarantees":"ATLEAST_ONCE","retainOrdering":true,"retainKeyOrdering":true,"batchBuilder":"","forwardSourceMessageProperty":true,"userConfig":{},"secrets":{},"runtime":"JAVA","autoAck":true,"maxMessageRetries":0,"deadLetterTopic ":"","subName ":"","parallelism ":2,"resources ":{"cpu ":1.0,"ram...
### 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/7870706938?check_suite_focus=true ### Exception stacktrace Error: Tests run: 15, Failures: 1, Errors: 0,...
