[pulsar] branch master updated (a8701c1 -> 0996327)
This is an automated email from the ASF dual-hosted git repository. sijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from a8701c1 [docs] minor formatting fix (#7040) add 0996327 Fix segmentation fault if handleSendTimeout() is called after closeAsync() (#6827) No new revisions were added by this update. Summary of changes: pulsar-client-cpp/lib/ProducerImpl.cc | 53 +-- pulsar-client-cpp/lib/ProducerImpl.h | 4 +++ 2 files changed, 42 insertions(+), 15 deletions(-)
[pulsar] branch master updated: [docs] minor formatting fix (#7040)
This is an automated email from the ASF dual-hosted git repository. sijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/master by this push: new a8701c1 [docs] minor formatting fix (#7040) a8701c1 is described below commit a8701c13b3871ecc65f56639adbf249dbd2cf231 Author: Raman Gupta AuthorDate: Tue May 26 02:35:25 2020 -0400 [docs] minor formatting fix (#7040) --- site2/docs/reference-pulsar-admin.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/site2/docs/reference-pulsar-admin.md b/site2/docs/reference-pulsar-admin.md index 259b242..d64b131 100644 --- a/site2/docs/reference-pulsar-admin.md +++ b/site2/docs/reference-pulsar-admin.md @@ -1282,7 +1282,7 @@ Usage $ pulsar-admin namespaces get-dispatch-rate tenant/namespace ``` -### set-replicator-dispatch-rate +### `set-replicator-dispatch-rate` Set replicator message-dispatch-rate for all topics of the namespace Usage @@ -1297,7 +1297,7 @@ Options |`-dt`, `--dispatch-rate-period`|The dispatch rate period in second type (default 1 second will be overwrite if not passed)|1| |`-md`, `--msg-dispatch-rate`|The message dispatch rate (default -1 will be overwrite if not passed)|-1| -### get-replicator-dispatch-rate +### `get-replicator-dispatch-rate` Get replicator configured message-dispatch-rate for all topics of the namespace (Disabled if value < 0) Usage
[pulsar] branch master updated (545658b -> 4129f6b)
This is an automated email from the ASF dual-hosted git repository. sijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 545658b Update admin-api-brokers.md (#7035) add 4129f6b Specify namespace when launching pulsar-manager (#7037) No new revisions were added by this update. Summary of changes: site2/docs/getting-started-helm.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[pulsar] branch master updated (806b83f -> 545658b)
This is an automated email from the ASF dual-hosted git repository. sijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 806b83f Make the json node field public to be able to extract it in the places where it is needed. (#7020) add 545658b Update admin-api-brokers.md (#7035) No new revisions were added by this update. Summary of changes: site2/docs/admin-api-brokers.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-)
[pulsar] branch master updated (b021871 -> 806b83f)
This is an automated email from the ASF dual-hosted git repository. sijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from b021871 [docs] Fix spelling error (#7039) add 806b83f Make the json node field public to be able to extract it in the places where it is needed. (#7020) No new revisions were added by this update. Summary of changes: .../apache/pulsar/client/impl/schema/generic/GenericJsonRecord.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-)
[pulsar] branch master updated: [docs] Fix spelling error (#7039)
This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/master by this push: new b021871 [docs] Fix spelling error (#7039) b021871 is described below commit b021871c91381ff086d3303e60c9c6b2f034c444 Author: Raman Gupta AuthorDate: Tue May 26 02:03:48 2020 -0400 [docs] Fix spelling error (#7039) --- site2/docs/reference-pulsar-admin.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/site2/docs/reference-pulsar-admin.md b/site2/docs/reference-pulsar-admin.md index 1ea946b..259b242 100644 --- a/site2/docs/reference-pulsar-admin.md +++ b/site2/docs/reference-pulsar-admin.md @@ -1138,7 +1138,7 @@ $ pulsar-admin namespaces set-persistence tenant/namespace options Options |Flag|Description|Default| ||---|---| -|`-a`, `--bookkeeper-ack-quorom`|The number of acks (guaranteed copies) to wait for each entry|0| +|`-a`, `--bookkeeper-ack-quorum`|The number of acks (guaranteed copies) to wait for each entry|0| |`-e`, `--bookkeeper-ensemble`|The number of bookies to use for a topic|0| |`-w`, `--bookkeeper-write-quorum`|How many writes to make of each entry|0| |`-r`, `--ml-mark-delete-max-rate`|Throttling rate of mark-delete operation (0 means no throttle)||
[GitHub] [pulsar] BewareMyPower commented on pull request #6827: [Issue 6822][C++] Fix segmentation fault if handleSendTimeout() is called after closeAsync()
BewareMyPower commented on pull request #6827: URL: https://github.com/apache/pulsar/pull/6827#issuecomment-633515394 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [pulsar] BewareMyPower opened a new pull request #7034: [C++] Fix Result can't be serialized to string inside the library
BewareMyPower opened a new pull request #7034:
URL: https://github.com/apache/pulsar/pull/7034
### Motivation
When a `Result` was passed to `std::ostream::operator<<` inside the library,
the overloaded `operator<<` wouldn't be called. Instead `Result` was treated as
a integer. For example, if you subscribed to a topic of a namespace that didn't
exist, the error log would be:
> ERROR ClientImpl:384 | Error Checking/Getting Partition Metadata while
Subscribing on persistent://mytenant/myns/mytopic -- 5
Giving following code:
```c++
namespace pulsar {
void foo() {
std::stringstream ss;
Result result = ResultOk;
ss << result; // "0"
}
}
void foo() {
std::stringstream ss;
Result result = ResultOk;
ss << result; // "Ok"
}
```
`ss << result` inside namespace `pulsar` doesn't call `::operator(ss,
result)`. Instead, it calls `pulsar::operator(ss, result)`, which hasn't been
overloaded. Because nearly all methods are in namespace `pulsar`, the
`LOG_XXX(... << result)` won't call `::operator<<(std::ostream&, Result)`.
### Modifications
- Change the overloaded `operator<<` for `Result` from global namespace to
namespace `pulsar`.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[GitHub] [pulsar] rajasekar33 commented on issue #7019: Webhook Size is always zero
rajasekar33 commented on issue #7019: URL: https://github.com/apache/pulsar/issues/7019#issuecomment-633508599 Hi Team Ming Luo helped me to solve this problem, I haven't registered webhook with DB thats why it was showing zero This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [pulsar] rdhabalia opened a new pull request #6566: [PIP-60] [Proxy-Server] Support SNI routing to support various proxy-server in pulsar
rdhabalia opened a new pull request #6566: URL: https://github.com/apache/pulsar/pull/6566 ### Motivation Implementation of [PIP-60](https://github.com/apache/pulsar/wiki/PIP-60:-Support-Proxy-server-with-SNI-routing) A proxy server is a go‑between or intermediary server that forwards requests from multiple clients to different servers across the Internet. The proxy server can act as a “traffic cop,” in both forward and reverse proxy scenarios, and adds various benefits in your system such as load balancing, performance, security, auto-scaling, etc.. There are already many proxy servers already available in the market which are fast, scalable and more importantly covers various essential security aspects that are needed by the large organization to securely share their confidential data over the network. Pulsar already provides proxy implementation PIP-1 which acts as a reverse proxy and creates a gateway in front of brokers. However, pulsar doesn’t provide support to use other proxies such as Apache traffic server (ATS), HAProxy, Nginx, Envoy those are more scalable and secured. Most of these proxy-servers support SNI ROUTING which can route traffic to a destination without having to terminate the SSL connection. Routing at layer 4 gives greater transparency because the outbound connection is determined by examining the destination address in the client TCP packets. [Netty supports sending SNI header on TLS handshake](https://github.com/netty/netty/issues/3801#issuecomment-104274440) and this PR uses that Netty feature to send SNI header while connecting to proxy. ### Modification https://github.com/apache/pulsar/wiki/PIP-60:-Support-Proxy-server-with-SNI-routing#changes **Note:** we have fully tested this changes with ATS proxy for both forward and reverse proxy scenarios. And I have also shared e2e example in PIP to use ATS proxy for client and broker integration. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [pulsar] codelipenghui closed pull request #6566: [PIP-60] [Proxy-Server] Support SNI routing to support various proxy-server in pulsar
codelipenghui closed pull request #6566: URL: https://github.com/apache/pulsar/pull/6566 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [pulsar] codelipenghui commented on pull request #7024: [Issue 7022][Prometheus]Fix for topic out Prometheus metrics
codelipenghui commented on pull request #7024: URL: https://github.com/apache/pulsar/pull/7024#issuecomment-633495006 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [pulsar] codelipenghui commented on pull request #6719: fix consumer fetch message number maps to read entry number bug and expose avgMessagesPerEntry metric
codelipenghui commented on pull request #6719: URL: https://github.com/apache/pulsar/pull/6719#issuecomment-633490608 @hangc0276 Looks good to me. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [pulsar] zplinuxlover commented on pull request #6903: PIP-61: Advertise multiple addresses
zplinuxlover commented on pull request #6903: URL: https://github.com/apache/pulsar/pull/6903#issuecomment-633487642 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[pulsar] branch website created (now d243808)
This is an automated email from the ASF dual-hosted git repository. zhaijia pushed a change to branch website in repository https://gitbox.apache.org/repos/asf/pulsar.git. at d243808 fix bc version No new revisions were added by this update.
[GitHub] [pulsar] ayolivia opened a new issue #7033: Ledger dir is redundant when using an existing bookkeeper cluster
ayolivia opened a new issue #7033: URL: https://github.com/apache/pulsar/issues/7033 **Describe the bug** Currently, we can use an existing bookkeeper cluster by parameter `bookkeeperMetadataServiceUri` (based master branch), however, the ledger dir (`/ledgers`) is still created in pulsar metadata store when initialize cluster metadata. This may confuse some users when trying to locate bookie nodes. **Expected behavior** Create the ledger dir when necessary. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [pulsar] wolfstudy merged pull request #7031: Add pulsar SQL woker metrics to repo
wolfstudy merged pull request #7031: URL: https://github.com/apache/pulsar/pull/7031 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[pulsar] branch master updated (7880425 -> d4d380a)
This is an automated email from the ASF dual-hosted git repository. rxl pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 7880425 Fix presto SQL does not start prometheus service by default (#7030) add d4d380a Add pulsar SQL woker metrics to repo (#7031) No new revisions were added by this update. Summary of changes: conf/presto/catalog/pulsar.properties | 5 .../sql/presto/PulsarConnectorMetricsTracker.java | 23 + site2/docs/reference-metrics.md| 29 ++ 3 files changed, 46 insertions(+), 11 deletions(-)
[GitHub] [pulsar] wolfstudy closed issue #6897: [document] document for Pulsar SQL worker metrics.
wolfstudy closed issue #6897: URL: https://github.com/apache/pulsar/issues/6897 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [pulsar] wolfstudy merged pull request #7030: [Issue: 7029] Fix presto SQL does not start prometheus service by default
wolfstudy merged pull request #7030: URL: https://github.com/apache/pulsar/pull/7030 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [pulsar] wolfstudy closed issue #7029: By default, presto SQL does not start the prometheus service
wolfstudy closed issue #7029: URL: https://github.com/apache/pulsar/issues/7029 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[pulsar] branch master updated (cd77772 -> 7880425)
This is an automated email from the ASF dual-hosted git repository. rxl pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from cd2 Add the pulsar functions metrics (#7016) add 7880425 Fix presto SQL does not start prometheus service by default (#7030) No new revisions were added by this update. Summary of changes: .../src/main/java/org/apache/pulsar/sql/presto/PulsarConnector.java | 4 .../java/org/apache/pulsar/sql/presto/PulsarConnectorFactory.java | 4 +++- 2 files changed, 7 insertions(+), 1 deletion(-)
[GitHub] [pulsar] ADHB opened a new issue #7032: Pulsar supporting DLQ for sources/sinks
ADHB opened a new issue #7032: URL: https://github.com/apache/pulsar/issues/7032 Currently Pulsar doesn't support DLQ for sources and sinks. Only functions support DLQ. It is very important for sinks like ElasticSearch which is widely used in production env for logging systems to be able to redirect unacknowledged messages to another topic , keeping otherwise the brokers running as normal. I would like to see a setting in consumer.conf or broker.conf that enables DLQ on a Pulsar configuration, so DLQ will be turned on for sources, sinks or any functions. or I would like to create a sink/sources with an extra --DLQ parameter. Giving a topic to the parameter will turn on DLQ. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [pulsar] zplinuxlover commented on pull request #6903: PIP-61: Advertise multiple addresses
zplinuxlover commented on pull request #6903: URL: https://github.com/apache/pulsar/pull/6903#issuecomment-633433590 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [pulsar] hangc0276 commented on pull request #6719: fix consumer fetch message number maps to read entry number bug and expose avgMessagesPerEntry metric
hangc0276 commented on pull request #6719: URL: https://github.com/apache/pulsar/pull/6719#issuecomment-633423823 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [pulsar] codelipenghui closed issue #6655: Retention policy should be respected when there is no traffic
codelipenghui closed issue #6655: URL: https://github.com/apache/pulsar/issues/6655 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [pulsar] codelipenghui commented on issue #6655: Retention policy should be respected when there is no traffic
codelipenghui commented on issue #6655: URL: https://github.com/apache/pulsar/issues/6655#issuecomment-633413531 close via #6676 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [pulsar] zplinuxlover commented on pull request #6903: PIP-61: Advertise multiple addresses
zplinuxlover commented on pull request #6903: URL: https://github.com/apache/pulsar/pull/6903#issuecomment-633413159 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
