- 30 3月, 2019 11 次提交
-
-
由 Fangbin Sun 提交于
* Support '--help' option of Pulsar command-line tools. * Fix a indentation * Fix a minor bug
-
由 massakam 提交于
-
由 Sijie Guo 提交于
*Motivation* Fixes #3651 `pulsar-io-debezium` is a normal module but not a connector package. it was added as a connector package by mistake at #3601. This would cause failing to load connectors during broker starts up. *Changes* - remove nar plugin from `pulsar-io-debezium` - remove `pulsar-io-debezium` from distribution - add `pulsar-io-kafka-connect-adaptor` in the website
-
由 Boyang Jerry Peng 提交于
* allow for graceful shutdown when running functions in kubernetes * cleaning up * fix unit tests
-
由 Boyang Jerry Peng 提交于
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
* Use default queue size in function producer * Fixed queue size
-
由 Matteo Merli 提交于
* Fixed C++ batch acks tracker to evict message from sendList array * Fixed formatting
-
由 Boyang Jerry Peng 提交于
-
由 Boyang Jerry Peng 提交于
* adding memory padding to memory limits set in kubernetes * cleaning up
-
由 Boyang Jerry Peng 提交于
* fix: add retry and wait for kubernetes creation/deletion * cleaning up * adding retry logic for cleaning up subscriptions * adjust number of retries * correcting namespace
-
- 15 2月, 2019 4 次提交
-
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
### Motivation Fixes the Apache RAT check to exclude the auto-generated files from Avro compiler and Avro JSON schema definitions.
-
由 Matteo Merli 提交于
### Motivation Building Python wheels is failing in the updated Docker image for Python 3.4, 3.5 and 3.6. Fixing it here by explicitly including the library defined variables.
-
由 Matteo Merli 提交于
-
- 14 2月, 2019 8 次提交
-
-
由 Fangbin Sun 提交于
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
### Motivation Fixed flaky test in `AuthPluginTest.testTlsDetectPulsarSslWithHostNameValidation`. The failure was due to the fact that test is creating a producer asynchronously but not waiting for the future to be completed.
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
* If no clusters are specified, the namespace should by default use current cluster * Don't apply to v1 local namespaces * It's better to use the isV2() check instead of isGlobal()
-
由 Rajan Dhabalia 提交于
[pulsar-broker] provide option to disable redelivery-tracker to reduce in memory positionImpl footprint and gc improvement (#3584) * [pulsar-broker] provide option to disable redelivery-tracker to reduce in memory positionImpl footprint and gc improvement * change config name
-
由 Fangbin Sun 提交于
-
- 13 2月, 2019 10 次提交
-
-
由 Enrico Olivelli 提交于
[Issue 3458: Tag Pulsar ledgers in order to distinguish from other leggers in the same Bookkeeper cluster (#3525) Fixes #3458 ### Motivation See #3458 ### Modifications Add a new LedgerMetadataUtils class which holds the logic for building "metadata" to be attached to ### Verifying this change This change is a trivial rework / code cleanup without any test coverage.
-
由 冉小龙 提交于
* [go client] add SubscriptionInitPos option in ConsumerOptions Signed-off-by: Nxiaolong.ran <ranxiaolong716@gmail.com> * add comment for SubscriptionInitPos option Signed-off-by: Nxiaolong.ran <ranxiaolong716@gmail.com>
-
由 Vincent Xie 提交于
Signed-off-by: NVinceShieh <vinceshieh@gmail.com>
-
由 冉小龙 提交于
* [go client] add validation hostName for ClientOptions Signed-off-by: Nxiaolong.ran <ranxiaolong716@gmail.com> * [go client] add validation hostName for ClientOptions Signed-off-by: Nxiaolong.ran <ranxiaolong716@gmail.com> * rename ValidationHostName to TLSValidateHostname Signed-off-by: Nxiaolong.ran <ranxiaolong716@gmail.com>
-
由 Matteo Merli 提交于
-
由 Bruno Bonnin 提交于
### Motivation Provides a builtin MongoDB Connector, in order to ease the storage of JSON formated message in MongoDB. It's a sink connector. ### Modifications Add a new sub-module in the `pulsar-io`module. ### Verifying this change This change added tests and can be verified as follows: * deploy the connector with configuration file containing the following fields: ``` configs: mongoUri: mongodb://hostname:port database: pulsar collection: messages ``` * start a mongodb instance * send messages in the topic declared when deploying the connector * check in MongoDB if the messages have been stored in the collection `messages`
-
由 Sanjeev Kulkarni 提交于
* moved all windowing related code into its own submodule. * added pom
-
由 Matteo Merli 提交于
-
由 Fangbin Sun 提交于
-
由 冉小龙 提交于
* [cpp-client] add multi topic for consumer #3494 Signed-off-by: Nxiaolong.ran <ranxiaolong716@gmail.com> * use initial_position instead to multi-topics Signed-off-by: Nxiaolong.ran <ranxiaolong716@gmail.com>
-
- 12 2月, 2019 4 次提交
-
-
由 Rajan Dhabalia 提交于
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
* Added docs for using schema in Python client lib * Added info on required fields
-
- 11 2月, 2019 3 次提交
-
-
由 Fangbin Sun 提交于
### Motivation Add a unit test for KafkaAbstractSink to check valid configs. ### Modifications Add KafkaAbstractSinkTest.
-
由 Sijie Guo 提交于
*Motivation* Add state support in python functions *Changes* - Bump bookkeeper version, so the table service has the changes to support python functions - Add state to python function
-
由 Matteo Merli 提交于
-