- 24 10月, 2019 7 次提交
-
-
由 cckellogg 提交于
* Add test for links to other markdown docs. * Remove unused import.
-
由 Pierre Zemb 提交于
-
由 lipenghui 提交于
### Motivation Add support for partitioned topic consumer seek by time. ### Modifications Call each partition consumer seekAsync() while call partitioned consumer seekAsync() ### Verifying this change Update unit tests for consumer.seek().
-
由 冉小龙 提交于
Signed-off-by: Nxiaolong.ran <ranxiaolong716@gmail.com> [Docs] Add functions-worker commands for pulsar admin CLI
-
由 Rajan Dhabalia 提交于
* [pulsar-perf] Add batching max message into perf-producer * add default values
-
由 冉小龙 提交于
Signed-off-by: Nxiaolong.ran <ranxiaolong716@gmail.com>
-
由 Ivan Kelly 提交于
After compaction completes the compacted ledger is recorded as a property of a cursor. As persisting the cursor is async and we don't wait for the acknowledgement of the acknowledgement, there may be a race if we try to read the compacted ledger immediately. To avoid this race, I've added a 1 second sleep to allow the compacted ledger to be updated on the broker.
-
- 23 10月, 2019 12 次提交
-
-
由 Boyang Jerry Peng 提交于
* Make Function Authentication Provider pluaggable * add config comments * cleaning up * cleaning up * fix test
-
由 Matteo Merli 提交于
-
由 Rajan Dhabalia 提交于
* [pulsar-broker] Fix: race condition : Failed to read-more entries on dispatcher * clean up non-used method
-
由 Jennifer Huang 提交于
* Update logo path for Pulsar users * Fix logo background for HSL and One click retail
-
由 hrsakai 提交于
-
由 Like 提交于
-
由 Masahiro Sakamoto 提交于
* Fix bug that namespace policies does not take effect due to NPE * Prevent NPE if Dispatcher and DispatchRateLimiter return to null
-
由 Matteo Merli 提交于
-
由 Rajan Dhabalia 提交于
-
由 かとかい 提交于
-
由 Boyang Jerry Peng 提交于
* fix potential deadlock that can occur in addConsumer * add fix to PersistentDispatcherSingleActiveConsumer * fixing tests
-
由 即将奔跑的蜗牛 提交于
Signed-off-by: KevenYLi <liyi.changde@gmail.com>
-
- 22 10月, 2019 2 次提交
-
-
由 Boyang Jerry Peng 提交于
-
由 Boyang Jerry Peng 提交于
This reverts commit d49e61e0.
-
- 21 10月, 2019 1 次提交
-
-
由 冉小龙 提交于
### Motivation The `Send(context.Context, ProducerMessage) error` should return `MessageID`. ``` SendAsync(context.Context, ProducerMessage, func(ProducerMessage, error)) ```
-
- 17 10月, 2019 1 次提交
-
-
由 Anonymitaet 提交于
-
- 16 10月, 2019 1 次提交
-
-
由 Chris Bartholomew 提交于
-
- 15 10月, 2019 1 次提交
-
-
由 lipenghui 提交于
-
- 11 10月, 2019 2 次提交
-
-
由 chanruida 提交于
fix full-width “” to half-width "
-
由 Anonymitaet 提交于
-
- 10 10月, 2019 8 次提交
-
-
由 lipenghui 提交于
* Not allow use acknowledgeCumulative on Key_shared subscription. * fix comments * C++ Client add acknowledgeCumulative not allowed check.
-
由 Anonymitaet 提交于
* Add *Kinesis source connector guide* * update * Update
-
由 Ivan Kelly 提交于
There's a bug in how user metadata is attached to a block that if the user doesn't specify both the region and the endpoint, offloading will throw an exception, as you can't add a null value to an immutable map. This change elides null to the empty string in these cases, so that offloading can continue.
-
由 Masahiro Sakamoto 提交于
Master Issue: #5234 ### Motivation The other day, I fixed a memory leak caused by not being executed the destructor of C++ producer in #5246. However, when running a producer application written in Go in an environment with the modified C++ client library installed, the program occasionally crashes due to a "bad_weak_ptr" error. ``` 2019/10/01 16:34:30.210 c_client.go:68: [info] INFO | ProducerImpl:481 | [persistent://massakam/global/test/t1, dc1-904-1012912] Closing producer for topic persistent://massakam/global/test/t1 2019/10/01 16:34:30.211 c_client.go:68: [info] INFO | ProducerImpl:463 | Producer - [persistent://massakam/global/test/t1, dc1-904-1012912] , [batchMessageContainer = { BatchContainer [size = 0] [batchSizeInBytes_ = 0] [maxAllowedMessageBatchSizeInBytes_ = 131072] [maxAllowedNumMessagesInBatch_ = 1000] [topicName = persistent://massakam/global/test/t1] [producerName_ = dc1-904-1012912] [batchSizeInBytes_ = 0] [numberOfBatchesSent = 1] [averageBatchSize = 1]}] 2019/10/01 16:34:30.211 c_client.go:68: [info] INFO | BatchMessageContainer:171 | [numberOfBatchesSent = 1] [averageBatchSize = 1] terminate called after throwing an instance of 'std::bad_weak_ptr' what(): 2019/10/01 16:34:30.211 c_client.go:68: [info] INFO | ProducerImpl:463 | Producer - [persistent://massakam/global/test/t1, dc1-904-1012911] , [batchMessageContainer = { BatchContainer [size = 0] [batchSizeInBytes_ = 0] [maxAllowedMessageBatchSizeInBytes_ = 131072] [maxAllowedNumMessagesInBatch_ = 1000] [topicName = persistent://massakam/global/test/t1] [producerName_ = dc1-904-1012911] [batchSizeInBytes_ = 0] [numberOfBatchesSent = 1] [averageBatchSize = 1]}] bad_weak_ptr 2019/10/01 16:34:30.211 c_client.go:68: [info] INFO | BatchMessageContainer:171 | [numberOfBatchesSent = 1] [averageBatchSize = 1] 2019/10/01 16:34:30.211 c_client.go:68: [info] INFO | ProducerImpl:463 | Producer - [persistent://massakam/global/test/t1, dc1-904-1012910] , [batchMessageContainer = { BatchContainer [size = 0] [batchSizeInBytes_ = 0] [maxAllowedMessageBatchSizeInBytes_ = 131072] [maxAllowedNumMessagesInBatch_ = 1000] [topicName = persistent://massakam/global/test/t1] [producerName_ = dc1-904-1012910] [batchSizeInBytes_ = 0] [numberOfBatchesSent = 1] [averageBatchSize = 1]}] SIGABRT: abort PC=0x7fc78d39d2c7 m=0 sigcode=18446744073709551610 ``` As a result of the investigation, I found that the destructor was called before the process of closing `ProducerImpl` was completed, and the object was destroyed. ### Modifications To keep the `ProducerImpl` object alive, get its own shared pointer at the beginning of `ProducerImpl::closeAsync()`. And the pointer must be passed to `ProducerImpl::handleClose()`. Otherwise, the object will be destroyed before `handleClose()` is called. So far, this issue has not been reproduced in `ConsumerImpl`, but I fixed it in the same way as `ProducerImpl`.
-
由 Ali Ahmed 提交于
-
由 冉小龙 提交于
[Docs] Add putstate, set-replicator-dispatch-rate and get-replicator-dispatch-rate cli docs for pulsar admin (#5338) Signed-off-by: Nxiaolong.ran <ranxiaolong716@gmail.com> ### Motivation In [pulsar-admin](https://pulsar.apache.org/docs/en/pulsar-admin), we have not listed the document information related to the `putstate`, `set-replicator-dispatch-rate` and `get-replicator-dispatch-rate`command. ### Modifications *Describe the modifications you've done.* Add `putstate` command for **pulsar-admin functions**. Add `set-replicator-dispatch-rate` command for **pulsar-admin namespaces**. Add `get-replicator-dispatch-rate` command for **pulsar-admin namespaces**.
-
由 Anonymitaet 提交于
* Add *HDFS2 sink connector guide* * Update * Update
-
由 hrsakai 提交于
-
- 09 10月, 2019 3 次提交
-
-
由 Matteo Merli 提交于
-
由 Masahiro Sakamoto 提交于
### Motivation If cursor is not durable, the subscription is closed and removed from the topic when all consumers are removed. https://github.com/apache/pulsar/blob/413ba03050036a620fa346456ef6c3ff6071e9ab/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java#L237-L254 As mentioned in #5288, the dispatcher also needs to be closed at this time. Otherwise, `RateLimiter` instances will not be garbage collected, causing a memory leak.
-
由 Matteo Merli 提交于
-
- 08 10月, 2019 2 次提交
-
-
由 Matteo Merli 提交于
* Ensure the handling of PartitionMetadataRequest is async end-to-end * Fixed z-node path
-
由 即将奔跑的蜗牛 提交于
Signed-off-by: KevenYLi <liyi.changde@gmail.com>
-