zymap opened a new pull request #313:
URL: https://github.com/apache/pulsar-client-go/pull/313
*Motivation*
Support oauth2 authentication for pulsar-client-go
This is an automated message from the Apache Git Service.
T
jerrypeng commented on a change in pull request #7474:
URL: https://github.com/apache/pulsar/pull/7474#discussion_r451310965
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/MembershipManager.java
##
@@ -225,7 +232,8 @@ public void checkFa
jerrypeng commented on a change in pull request #7474:
URL: https://github.com/apache/pulsar/pull/7474#discussion_r451308305
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java
##
@@ -368,8 +390,13 @@ private void invoke
jerrypeng commented on a change in pull request #7474:
URL: https://github.com/apache/pulsar/pull/7474#discussion_r451308599
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java
##
@@ -526,4 +553,118 @@ static String chec
aloyszhang edited a comment on issue #7476:
URL: https://github.com/apache/pulsar/issues/7476#issuecomment-655260885
Addtionally, ZooKeeper has no error.
And we dump the discovery process, found that `BrokerDiscoveryProvider`
does not has availableBrokers in its `ZookeeperCacheLoader` b
aloyszhang commented on issue #7476:
URL: https://github.com/apache/pulsar/issues/7476#issuecomment-655260885
Addtionally, ZooKeeper has no error.
And we dump the discovery process, found that `BrokerDiscoveryProvider`
does not has availableBrokers in its `ZookeeperCacheLoader` but
`Di
aloyszhang opened a new issue #7476:
URL: https://github.com/apache/pulsar/issues/7476
**Describe the bug**
Discovery service can't find active broker when all brokers are running well.
`21:05:33.529 [pulsar-discovery-io-2-1] WARN
org.apache.pulsar.discovery.service.ServerConnection
liudezhi2098 closed pull request #7458:
URL: https://github.com/apache/pulsar/pull/7458
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
liudezhi2098 closed issue #7457:
URL: https://github.com/apache/pulsar/issues/7457
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 t
srkukarni commented on a change in pull request #7474:
URL: https://github.com/apache/pulsar/pull/7474#discussion_r451255338
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java
##
@@ -526,4 +553,118 @@ static String chec
srkukarni commented on a change in pull request #7474:
URL: https://github.com/apache/pulsar/pull/7474#discussion_r451254764
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/MembershipManager.java
##
@@ -225,7 +232,8 @@ public void checkFa
feeblefakie edited a comment on issue #7455:
URL: https://github.com/apache/pulsar/issues/7455#issuecomment-654763271
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
wolfstudy commented on issue #52:
URL: https://github.com/apache/pulsar-client-go/issues/52#issuecomment-655245754
> Is there any plan for Interceptor?
The feature LGTM+1, @snowcrumble If you are interested in this, can you send
a pull request to impl this?
taiyang-li commented on a change in pull request #303:
URL: https://github.com/apache/pulsar-client-go/pull/303#discussion_r451241499
##
File path: pulsar/consumer_singletopic.go
##
@@ -0,0 +1,41 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more cont
Anonymitaet commented on issue #6243:
URL: https://github.com/apache/pulsar/issues/6243#issuecomment-655232251
Docs are available
[here](https://streamnative.io/docs/latest/process/pulsar-functions/develop/feature).
Need to copy to the Pulsar website.
--
Anonymitaet closed issue #6243:
URL: https://github.com/apache/pulsar/issues/6243
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 th
Jennifer88huang commented on pull request #7471:
URL: https://github.com/apache/pulsar/pull/7471#issuecomment-655231601
@rdhabalia thank you very much for your advice. I'll ping you when I finish
the structure and content refining.
-
shohi edited a comment on issue #296:
URL:
https://github.com/apache/pulsar-client-go/issues/296#issuecomment-650673683
Take a step back, is it possible for the library to support customized error
handlers for failures of sending Ack/Nack request as both of them are
non-blocking?
merlimat merged pull request #7465:
URL: https://github.com/apache/pulsar/pull/7465
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
merlimat commented on a change in pull request #7474:
URL: https://github.com/apache/pulsar/pull/7474#discussion_r451230995
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java
##
@@ -368,8 +390,13 @@ private void invokeR
merlimat closed issue #5736:
URL: https://github.com/apache/pulsar/issues/5736
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 s
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 77dccd2 Differentiate authorization between source/sink/function
operations (#7466)
add c91505e [Issue 5736]
merlimat opened a new pull request #7475:
URL: https://github.com/apache/pulsar/pull/7475
### Motivation
When using CPU limits on a docker container, the CPU usage on the broker
load report will result incorrect.
We're reporting the CPU usage such as:
```json
"cpu
jerrypeng opened a new pull request #7474:
URL: https://github.com/apache/pulsar/pull/7474
### Motivation
Add stats to be logged for schedule, rebalance, and check failure routines
for debugging and performance details
---
jiazhai commented on pull request #7467:
URL: https://github.com/apache/pulsar/pull/7467#issuecomment-655209589
/pulsarbot run-failure-checks
This is an automated message from the Apache Git Service.
To respond to the message
rdhabalia commented on pull request #7473:
URL: https://github.com/apache/pulsar/pull/7473#issuecomment-655206225
/pulsarbot run-failure-checks
This is an automated message from the Apache Git Service.
To respond to the messa
This is an automated email from the ASF dual-hosted git repository.
guangning pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-manager.git
The following commit(s) were added to refs/heads/master by this push:
new f4b3f22 Use PulsarAdmin instead of H
rdhabalia opened a new pull request #7473:
URL: https://github.com/apache/pulsar/pull/7473
### Motivation
We are having frequent issues when user removes cluster from the global
namespace where broker from removed-cluster fails to unload topic and namespace
bundle still loaded with the
srkukarni merged pull request #7466:
URL: https://github.com/apache/pulsar/pull/7466
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
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 77dccd2 Differentiate authorization between
TC-robV commented on issue #7260:
URL: https://github.com/apache/pulsar/issues/7260#issuecomment-655129291
ever figure this out? running into the same issues. no auth enabled though.
This is an automated message from the Apac
vzhikserg commented on a change in pull request #7472:
URL: https://github.com/apache/pulsar/pull/7472#discussion_r451106092
##
File path: site2/website/data/connectors.js
##
@@ -13,15 +13,27 @@ module.exports = [
},
{
name: 'cassandra',
-longName: 'A
srkukarni commented on pull request #7466:
URL: https://github.com/apache/pulsar/pull/7466#issuecomment-655060283
Added
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
jerrypeng commented on pull request #7466:
URL: https://github.com/apache/pulsar/pull/7466#issuecomment-655039973
@srkukarni can you add a note to the release notes about this?
This is an automated message from the Apache Git
rdhabalia commented on a change in pull request #7471:
URL: https://github.com/apache/pulsar/pull/7471#discussion_r451045916
##
File path: site2/docs/concepts-proxy-sni-routing.md
##
@@ -93,7 +93,7 @@
clientBuilder.authentication(AuthenticationTls.class.getName(), authParams);
rdhabalia commented on a change in pull request #7471:
URL: https://github.com/apache/pulsar/pull/7471#discussion_r451045541
##
File path: site2/docs/concepts-proxy-sni-routing.md
##
@@ -5,28 +5,28 @@ sidebar_label: Proxy support with SNI routing
---
## Pulsar Proxy with SN
sijie commented on issue #7407:
URL: https://github.com/apache/pulsar/issues/7407#issuecomment-655013920
It was closed because of `Fixes` comment in the description. I have reopened
it.
This is an automated message from the
fmiguelez opened a new issue #7407:
URL: https://github.com/apache/pulsar/issues/7407
**Describe the bug**
The solution provided by #7139 to the BUG #4803 *does not work*.
* When trying to read a message with `null` value a `NullPointerException`
is thrown in other part of the
wolfstudy commented on a change in pull request #310:
URL: https://github.com/apache/pulsar-client-go/pull/310#discussion_r450990843
##
File path: perf/perf-producer.go
##
@@ -62,6 +63,8 @@ func newProducerCommand() *cobra.Command {
"Publish rate. Set to 0 to go
wolfstudy commented on a change in pull request #310:
URL: https://github.com/apache/pulsar-client-go/pull/310#discussion_r450990843
##
File path: perf/perf-producer.go
##
@@ -62,6 +63,8 @@ func newProducerCommand() *cobra.Command {
"Publish rate. Set to 0 to go
merlimat commented on pull request #308:
URL: https://github.com/apache/pulsar-client-go/pull/308#issuecomment-654976606
> Sorry, @cckellogg About this, i don't think so. In what kind of scenarios,
the user needs to write a message to the MessageChannel?
If you are consuming from mul
sijia-w opened a new pull request #7472:
URL: https://github.com/apache/pulsar/pull/7472
Fix: #6116
### Motivation
Fix the issue 6116.
### Modifications
Fix the duplicate links for source and link download and put them in
alphabetical order.
### Verifying this ch
merlimat commented on a change in pull request #309:
URL: https://github.com/apache/pulsar-client-go/pull/309#discussion_r450984529
##
File path: pulsar/internal/connection.go
##
@@ -288,7 +288,7 @@ func (c *connection) doHandshake() bool {
if cmd.Connected == nil {
srkukarni commented on pull request #7466:
URL: https://github.com/apache/pulsar/pull/7466#issuecomment-654957607
Coming to think more about it, the existing sources/sinks will continue to
run fine. Thus upon upgrade of cluster, things still will work ok, except that
newer sources/sinks wi
wolfstudy edited a comment on pull request #311:
URL: https://github.com/apache/pulsar-client-go/pull/311#issuecomment-654579398
@merlimat @sijie Can you help add `GO_CLIENT_BOT_TOKEN` to security?
This is an automated messag
wolfstudy commented on pull request #308:
URL: https://github.com/apache/pulsar-client-go/pull/308#issuecomment-654952140
> I think the message channel option should remain because there are valid
use cases for it. The option needs to be read/write channel because the client
needs to write
Jennifer88huang commented on pull request #7471:
URL: https://github.com/apache/pulsar/pull/7471#issuecomment-654925625
I haven't finished refining yet, please do not review the content currently.
This is an automated message
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new 6a80299 Fix CompressMaxSize() for ZLi
merlimat merged pull request #312:
URL: https://github.com/apache/pulsar-client-go/pull/312
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 t
Jennifer88huang opened a new pull request #7471:
URL: https://github.com/apache/pulsar/pull/7471
Fixes #7421
### Motivation
The `sidebar.json` file is not updated, so the content added in the .md file
is not displayed on website.
### Modifications
1. Update the
Jennifer88huang commented on pull request #7421:
URL: https://github.com/apache/pulsar/pull/7421#issuecomment-654915425
@rdhabalia Thank you very much for your contribution.
To display the content, we need to refine the `sidebar.json` file as well.
I'll fix it in another PR.
--
codelipenghui closed pull request #7461:
URL: https://github.com/apache/pulsar/pull/7461
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 g
codelipenghui commented on pull request #7461:
URL: https://github.com/apache/pulsar/pull/7461#issuecomment-654898275
The compacted data is stored in a separate ledger, I think the cursor can't
read data from that ledger. You can see
https://github.com/apache/pulsar/blob/53407fc59828669079
codelipenghui commented on pull request #7461:
URL: https://github.com/apache/pulsar/pull/7461#issuecomment-654896700
The compacted data is stored in a separate ledger, I think the cursor can't
read data from that ledger. You can see
https://github.com/apache/pulsar/blob/53407fc59828669079
gaoran10 edited a comment on pull request #7461:
URL: https://github.com/apache/pulsar/pull/7461#issuecomment-654883130
1. I think we couldn't add the config `pulsar.read-compact`, this config is
a global config. It is up to users to query the raw data or the compacted data,
so we could ad
gaoran10 commented on pull request #7461:
URL: https://github.com/apache/pulsar/pull/7461#issuecomment-654883130
1. I think we couldn't add the config `pulsar.read-compact`, this config is
a global config. It is up to users to query the raw data or the compacted data,
so we could add metad
meleagle opened a new issue #7470:
URL: https://github.com/apache/pulsar/issues/7470
**Describe the bug**
The broker url for a broker will be set to whatever the advertisedAddress
and brokerServicePort are set to in the config when I only use a single
advertised listener. With pulsar 2.
meleagle opened a new issue #7469:
URL: https://github.com/apache/pulsar/issues/7469
**Describe the bug**
When using openmessaging (http://openmessaging.cloud) to benchmark a pulsar
cluster that we are using in openstack a NPE is being produced. The pulsar
version is 2.6.0 and there is
Huanli-Meng opened a new pull request #7468:
URL: https://github.com/apache/pulsar/pull/7468
### Motivation
Pulsar 2.4.0 release supports async state manipulation methods. The code is
updated while the doc is not updated accordingly. here is the code update PR:
https://github.com/apache
jiazhai opened a new pull request #7467:
URL: https://github.com/apache/pulsar/pull/7467
### Motivation
#7420 provides an Oauth2 auth client for java. This PR tries to support it
in cpp client
### Modifications
- add implementation
- add related tests.
feeblefakie edited a comment on issue #7455:
URL: https://github.com/apache/pulsar/issues/7455#issuecomment-654809462
I'm not sure but as far as I can see the code,
the following code could return different consumers for the same key if the
number of consumers is changed even if consist
feeblefakie commented on issue #7455:
URL: https://github.com/apache/pulsar/issues/7455#issuecomment-654809462
I'm not sure but as far as I can see,
the following code could return different consumers for the same key if the
number of consumers is changed even if consistent hashing or a
fmiguelez commented on issue #7407:
URL: https://github.com/apache/pulsar/issues/7407#issuecomment-654775988
I do not think that this ticket should be closed as pull request only solves
one of the cases described by the tests
---
feeblefakie commented on issue #7455:
URL: https://github.com/apache/pulsar/issues/7455#issuecomment-654763271
Here is what is happening.
For example, consumers for sub1 consumed messages with key "15" as follows.
```
#consumerName key value(produced-time)
messageId(ledgerId:entryI
snowcrumble commented on issue #52:
URL: https://github.com/apache/pulsar-client-go/issues/52#issuecomment-654734562
Is there any plan for Interceptor?
This is an automated message from the Apache Git Service.
To respond to t
This is an automated email from the ASF dual-hosted git repository.
guangning pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-manager.git
The following commit(s) were added to refs/heads/master by this push:
new ce023dc Change default port (#316)
c
Huanli-Meng commented on pull request #7462:
URL: https://github.com/apache/pulsar/pull/7462#issuecomment-654715374
@jiazhai , please help review the docs. Thanks.
This is an automated message from the Apache Git Service.
To
jiazhai commented on pull request #7430:
URL: https://github.com/apache/pulsar/pull/7430#issuecomment-654683263
/pulsarbot run-failure-checks
This is an automated message from the Apache Git Service.
To respond to the message
Jennifer88huang merged pull request #7421:
URL: https://github.com/apache/pulsar/pull/7421
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
This is an automated email from the ASF dual-hosted git repository.
hjf 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 ee1b810 [pulsar-doc] Add document for Pulasr SNI r
70 matches
Mail list logo
