[pulsar-client-node] annotated tag v1.3.1-rc.1 updated (cb581c9 -> 18ff6f0)

This is an automated email from the ASF dual-hosted git repository. hrsakai pushed a change to annotated tag v1.3.1-rc.1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-node.git. *** WARNING: tag v1.3.1-rc.1 was modified! *** from cb581c9 (commit) to 18ff6f0 (tag) t

[pulsar-client-node] branch branch-1.3 updated: 1.3.1-rc.1

This is an automated email from the ASF dual-hosted git repository. hrsakai pushed a commit to branch branch-1.3 in repository https://gitbox.apache.org/repos/asf/pulsar-client-node.git The following commit(s) were added to refs/heads/branch-1.3 by this push: new cb581c9 1.3.1-rc.1 cb581c9

[GitHub] [pulsar] shibd edited a comment on issue #11979: Topic stats "unackedMessages" not updated correctly for subscription and consumer

shibd edited a comment on issue #11979: URL: https://github.com/apache/pulsar/issues/11979#issuecomment-917815291 Currently, `unackedMessages` operates under the following scene: 1. Consumer use `Shard model` (SubscriptionType eq Shared / Key_Shared) 2. Consumer use `Individual ack

[GitHub] [pulsar] beyondyinjl2 opened a new issue #12022: How to dynamically produce and consume topic data

beyondyinjl2 opened a new issue #12022: URL: https://github.com/apache/pulsar/issues/12022 After creating a Producer, I want to send data to multiple different topics, or create a Consumer, I want to consume data from multiple topics -- This is an automated message from the Apache Git Se

[GitHub] [pulsar] Jennifer88huang commented on a change in pull request #12001: Add pulsar 2.8.1 release note

Jennifer88huang commented on a change in pull request #12001: URL: https://github.com/apache/pulsar/pull/12001#discussion_r707032631 ## File path: site2/website/release-notes.md ## @@ -1,6 +1,245 @@ ## Apache Pulsar Release Notes +### 2.8.1 — 2021-09-10 + +### Broker +- F

[GitHub] [pulsar] xuesongxs opened a new issue #12021: Send to retry letter topic exception with topic

xuesongxs opened a new issue #12021: URL: https://github.com/apache/pulsar/issues/12021 **Describe the bug** Pulsar v2.6.2 ``` org.apache.pulsar.client.api.PulsarClientException$InvalidMessageException: null at org.apache.pulsar.client.impl.ConsumerBase.reconsumeLaterA

[GitHub] [pulsar] yuruguo commented on a change in pull request #12020: [testclient] Make option -time take effect in PerformanceClient

yuruguo commented on a change in pull request #12020: URL: https://github.com/apache/pulsar/pull/12020#discussion_r707031944 ## File path: pulsar-testclient/src/main/java/org/apache/pulsar/proxy/socket/client/PerformanceClient.java ## @@ -185,13 +185,11 @@ public Arguments loa

[GitHub] [pulsar] zymap commented on a change in pull request #12020: [testclient] Make option -time take effect in PerformanceClient

zymap commented on a change in pull request #12020: URL: https://github.com/apache/pulsar/pull/12020#discussion_r707023470 ## File path: pulsar-testclient/src/main/java/org/apache/pulsar/proxy/socket/client/PerformanceClient.java ## @@ -185,13 +185,11 @@ public Arguments loadA

[GitHub] [pulsar] hozumit closed issue #11920: Topics occasionally remain unassigned. (Namespace is being unloaded, cannot add topic)

hozumit closed issue #11920: URL: https://github.com/apache/pulsar/issues/11920 -- 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. To unsubscribe, e-mail: commits-unsubscr..

[GitHub] [pulsar] hozumit commented on issue #11920: Topics occasionally remain unassigned. (Namespace is being unloaded, cannot add topic)

hozumit commented on issue #11920: URL: https://github.com/apache/pulsar/issues/11920#issuecomment-917861002 I've confirmed that the problem has been fixed in v2.8.1. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [pulsar] srouthu1 commented on issue #11652: deadLetterPolicy is not working with key shared subscription

srouthu1 commented on issue #11652: URL: https://github.com/apache/pulsar/issues/11652#issuecomment-917860180 @codelipenghui I am using 2.8 version -- 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 t

[pulsar-client-node] branch branch-1.3 updated: Fix compatibility between nodejs client and cpp client versions (#175)

This is an automated email from the ASF dual-hosted git repository. massakam pushed a commit to branch branch-1.3 in repository https://gitbox.apache.org/repos/asf/pulsar-client-node.git The following commit(s) were added to refs/heads/branch-1.3 by this push: new 18fb78f Fix compatibility

[GitHub] [pulsar-client-go] EAHITechnology commented on pull request #617: Use the time wheel structure instead of traversing the map && Add ackTimeout function

EAHITechnology commented on pull request #617: URL: https://github.com/apache/pulsar-client-go/pull/617#issuecomment-917855997 Add a time wheel to optimize the delay logic.At the same time add ack timeout -- This is an automated message from the Apache Git Service. To respond to the messa

[pulsar-client-node] branch master updated: Fix compatibility between nodejs client and cpp client versions (#176)

This is an automated email from the ASF dual-hosted git repository. massakam pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-client-node.git The following commit(s) were added to refs/heads/master by this push: new 499776e Fix compatibility between

[GitHub] [pulsar] yuruguo removed a comment on pull request #12016: [testclient] Add new option --num-messages for consumer and reader

yuruguo removed a comment on pull request #12016: URL: https://github.com/apache/pulsar/pull/12016#issuecomment-917849344 /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

[GitHub] [pulsar] yuruguo commented on pull request #12016: [testclient] Add new option --num-messages for consumer and reader

yuruguo commented on pull request #12016: URL: https://github.com/apache/pulsar/pull/12016#issuecomment-917849344 /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 th

[GitHub] [pulsar] yuruguo commented on pull request #12020: [testclient] Make option -time take effect in PerformanceClient

yuruguo commented on pull request #12020: URL: https://github.com/apache/pulsar/pull/12020#issuecomment-917835310 PTAL @merlimat @eolivelli @lhotari @codelipenghui @hangc0276 @315157973 @gaoran10 @congbobo184 @zymap -- This is an automated message from the Apache Git Service. To r

[GitHub] [pulsar] yuruguo opened a new pull request #12020: [testclient] Make option -time take effect in PerformanceClient

yuruguo opened a new pull request #12020: URL: https://github.com/apache/pulsar/pull/12020 ### Motivation The option `-time` is just defined but does not work in `PerformanceClient`, which causes the client not exit after reaching the test duration even if the user sets this option like

[GitHub] [pulsar] mostafij-rahman opened a new issue #12019: Flaky-test: ManagedLedgerTest.testMaximumRolloverTime

mostafij-rahman opened a new issue #12019: URL: https://github.com/apache/pulsar/issues/12019 ManagedLedgerTest is flaky. The testMaximumRolloverTime test method fails sporadically. ![ManagedLedgerTest testMaximumRolloverTime](https://user-images.githubusercontent.com/42969132/1

[GitHub] [pulsar] yuruguo removed a comment on pull request #12016: [testclient] Add new option --num-messages for consumer and reader

yuruguo removed a comment on pull request #12016: URL: https://github.com/apache/pulsar/pull/12016#issuecomment-917815495 /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

[GitHub] [pulsar] BewareMyPower opened a new pull request #12018: Avoid adding duplicated BrokerEntryMetadata

BewareMyPower opened a new pull request #12018: URL: https://github.com/apache/pulsar/pull/12018 ### Motivation When the Pulsar cluster enables broker entry metadata, sometimes there're some corrupted entries. See https://github.com/streamnative/kop/issues/442 for example. It's beca

[GitHub] [pulsar] yuruguo commented on pull request #12016: [testclient] Add new option --num-messages for consumer and reader

yuruguo commented on pull request #12016: URL: https://github.com/apache/pulsar/pull/12016#issuecomment-917815495 /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 th

[GitHub] [pulsar] shibd commented on issue #11979: Topic stats "unackedMessages" not updated correctly for subscription and consumer

shibd commented on issue #11979: URL: https://github.com/apache/pulsar/issues/11979#issuecomment-917815291 Currently, `unackedMessages` operates under the following scene: 1. Consumer use `Shard model` (SubscriptionType eq Shared / Key_Shared) 2. Consumer use `Individual ack`(consu

[pulsar] branch master updated: Update PMC list (#12011)

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 9b7c327 Update PMC list (#12011) 9b7c327 is descri

[GitHub] [pulsar] Jennifer88huang merged pull request #12011: [doc]Update PMC list

Jennifer88huang merged pull request #12011: URL: https://github.com/apache/pulsar/pull/12011 -- 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. To unsubscribe, e-mail: commi

[GitHub] [pulsar] yuruguo edited a comment on pull request #11973: [testclient] Improve parameter checking in pulsar-perf

yuruguo edited a comment on pull request #11973: URL: https://github.com/apache/pulsar/pull/11973#issuecomment-916148817 PTAL @merlimat @lhotari @eolivelli @codelipenghui @hangc0276 @315157973 @gaoran10 -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [pulsar] yuruguo commented on a change in pull request #11973: [testclient] Improve parameter checking in pulsar-perf

yuruguo commented on a change in pull request #11973: URL: https://github.com/apache/pulsar/pull/11973#discussion_r705821934 ## File path: pulsar-testclient/src/main/java/org/apache/pulsar/testclient/ParameterValidator.java ## @@ -0,0 +1,33 @@ +/** + * Licensed to the Apache S

[GitHub] [pulsar] yuruguo commented on a change in pull request #11985: [testclient] Call printAggregatedStats method before client exit

yuruguo commented on a change in pull request #11985: URL: https://github.com/apache/pulsar/pull/11985#discussion_r706975867 ## File path: pulsar-testclient/src/main/java/org/apache/pulsar/proxy/socket/client/SimpleTestProducerSocket.java ## @@ -45,6 +45,7 @@ @WebSocket(maxTe

[GitHub] [pulsar] wuzhanpeng commented on pull request #11993: [FEATURE] support for resetting logger level in runtime

wuzhanpeng commented on pull request #11993: URL: https://github.com/apache/pulsar/pull/11993#issuecomment-917793816 > This will only work for log4j, although it might not be the used logger. > > I think we should rely on the logger library to do this kind of operations. Log4j2 has a

[GitHub] [pulsar] yuruguo commented on a change in pull request #12016: [testclient] Add new option --num-messages for consumer and reader

yuruguo commented on a change in pull request #12016: URL: https://github.com/apache/pulsar/pull/12016#discussion_r706968811 ## File path: pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java ## @@ -293,6 +297,11 @@ public static void main(Stri

[GitHub] [pulsar] shibd commented on pull request #11998: [Broker] Need incrementUnackedMessages when send message to consumer(all subscribe mode)

shibd commented on pull request #11998: URL: https://github.com/apache/pulsar/pull/11998#issuecomment-917786603 > Looks good, can we add/update existing unit test to verify it? Probably at here: https://github.com/apache/pulsar/blob/master/pulsar-broker/src/test/java/org/apache/pulsar/brok

[GitHub] [pulsar] shibd closed pull request #11998: [Broker] Need incrementUnackedMessages when send message to consumer(all subscribe mode)

shibd closed pull request #11998: URL: https://github.com/apache/pulsar/pull/11998 -- 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. To unsubscribe, e-mail: commits-unsubsc

[GitHub] [pulsar] ravi-vaidyanathan commented on pull request #11957: [PIP-82] [pulsar-broker] Add missing permission check, fail update on non-existent ResourceGroup

ravi-vaidyanathan commented on pull request #11957: URL: https://github.com/apache/pulsar/pull/11957#issuecomment-917781917 /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 t

[GitHub] [pulsar] Jason918 commented on pull request #11960: [PIP-63] Readonly-Topic-Ownership-Support

Jason918 commented on pull request #11960: URL: https://github.com/apache/pulsar/pull/11960#issuecomment-917770759 /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 t

[GitHub] [pulsar] gaoran10 opened a new pull request #12017: [Branch-2.7][Build] Use ubuntu 20.04 as docker image base

gaoran10 opened a new pull request #12017: URL: https://github.com/apache/pulsar/pull/12017 ### Motivation Because the from ### Modifications *Describe the modifications you've done.* ### Verifying this change - [ ] Make sure that the change passes the CI c

[GitHub] [pulsar] ravi-vaidyanathan commented on pull request #11957: [PIP-82] [pulsar-broker] Add missing permission check, fail update on non-existent ResourceGroup

ravi-vaidyanathan commented on pull request #11957: URL: https://github.com/apache/pulsar/pull/11957#issuecomment-917759141 /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 t

[GitHub] [pulsar] ravi-vaidyanathan commented on pull request #11957: [PIP-82] [pulsar-broker] Add missing permission check, fail update on non-existent ResourceGroup

ravi-vaidyanathan commented on pull request #11957: URL: https://github.com/apache/pulsar/pull/11957#issuecomment-917723662 /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 t

[GitHub] [pulsar] ravi-vaidyanathan commented on pull request #11957: [PIP-82] [pulsar-broker] Add missing permission check, fail update on non-existent ResourceGroup

ravi-vaidyanathan commented on pull request #11957: URL: https://github.com/apache/pulsar/pull/11957#issuecomment-917714418 > We should add a test to ensure that there are not future regressions. @michaeljmarshall you are right, so added unit tests. -- This is an automated message

[GitHub] [pulsar] ravi-vaidyanathan commented on pull request #11957: [PIP-82] [pulsar-broker] Add missing permission check, fail update on non-existent ResourceGroup

ravi-vaidyanathan commented on pull request #11957: URL: https://github.com/apache/pulsar/pull/11957#issuecomment-917714162 /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 t

[pulsar] branch master updated (a43b622 -> eb0c662)

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from a43b622 Remove deprecated netty allocator tiny size (#12012) add eb0c662 [Broker] Cleanup: remove unnecessary

[GitHub] [pulsar] lhotari merged pull request #11994: [Broker] Cleanup: remove unnecessary boxing

lhotari merged pull request #11994: URL: https://github.com/apache/pulsar/pull/11994 -- 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. To unsubscribe, e-mail: commits-unsub

[GitHub] [pulsar] shibd removed a comment on pull request #11998: [Broker] Need incrementUnackedMessages when send message to consumer(all subscribe mode)

shibd removed a comment on pull request #11998: URL: https://github.com/apache/pulsar/pull/11998#issuecomment-917663949 > Looks good, can we add/update existing unit test to verify it? Probably at here: https://github.com/apache/pulsar/blob/master/pulsar-broker/src/test/java/org/apache/pul

[GitHub] [pulsar] shibd edited a comment on pull request #11998: [Broker] Need incrementUnackedMessages when send message to consumer(all subscribe mode)

shibd edited a comment on pull request #11998: URL: https://github.com/apache/pulsar/pull/11998#issuecomment-917663949 > Looks good, can we add/update existing unit test to verify it? Probably at here: https://github.com/apache/pulsar/blob/master/pulsar-broker/src/test/java/org/apache/puls

[GitHub] [pulsar] shibd commented on pull request #11998: [Broker] Need incrementUnackedMessages when send message to consumer(all subscribe mode)

shibd commented on pull request #11998: URL: https://github.com/apache/pulsar/pull/11998#issuecomment-917663949 > Looks good, can we add/update existing unit test to verify it? Probably at here: https://github.com/apache/pulsar/blob/master/pulsar-broker/src/test/java/org/apache/pulsar/brok

[GitHub] [pulsar] 315157973 commented on a change in pull request #12015: Fix update ledger list to znode version mismatch failed, ledger not delete

315157973 commented on a change in pull request #12015: URL: https://github.com/apache/pulsar/pull/12015#discussion_r706857155 ## File path: managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java ## @@ -1466,6 +1452,20 @@ public void operationFa

[GitHub] [pulsar] eolivelli commented on a change in pull request #12016: [testclient] Add new option --num-messages for consumer and reader

eolivelli commented on a change in pull request #12016: URL: https://github.com/apache/pulsar/pull/12016#discussion_r706856141 ## File path: pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java ## @@ -293,6 +297,11 @@ public static void main(St

[pulsar] branch branch-2.8 updated: Fix cherry-pick issue on branch-2.8 (#11982)

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-2.8 by this push: new ff51a02 Fix cherry-pick issue on bra

[GitHub] [pulsar] eolivelli merged pull request #11982: Fix cherry-pick issue on branch-2.8

eolivelli merged pull request #11982: URL: https://github.com/apache/pulsar/pull/11982 -- 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. To unsubscribe, e-mail: commits-uns

[GitHub] [pulsar] gaoran10 commented on a change in pull request #11986: [pulsar admin] getPartitionedTopicMetada method support setting auto create topic

gaoran10 commented on a change in pull request #11986: URL: https://github.com/apache/pulsar/pull/11986#discussion_r706854463 ## File path: pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/PersistentTopicsTest.java ## @@ -389,6 +392,27 @@ public void testNonPartition

[GitHub] [pulsar] gaoran10 commented on a change in pull request #11985: [testclient] Call printAggregatedStats method before client exit

gaoran10 commented on a change in pull request #11985: URL: https://github.com/apache/pulsar/pull/11985#discussion_r706851887 ## File path: pulsar-testclient/src/main/java/org/apache/pulsar/proxy/socket/client/SimpleTestProducerSocket.java ## @@ -45,6 +45,7 @@ @WebSocket(maxT

[GitHub] [pulsar] gaoran10 commented on a change in pull request #12015: Fix update ledger list to znode version mismatch failed, ledger not delete

gaoran10 commented on a change in pull request #12015: URL: https://github.com/apache/pulsar/pull/12015#discussion_r706849221 ## File path: managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java ## @@ -1466,6 +1452,20 @@ public void operationFai

[GitHub] [pulsar] shibd commented on a change in pull request #11986: [pulsar admin] getPartitionedTopicMetada method support setting auto create topic

shibd commented on a change in pull request #11986: URL: https://github.com/apache/pulsar/pull/11986#discussion_r706847552 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java ## @@ -786,6 +786,9 @@ public PartitionedTopicMetadata g

[GitHub] [pulsar] gaoran10 commented on a change in pull request #12016: [testclient] Add new option --num-messages for consumer and reader

gaoran10 commented on a change in pull request #12016: URL: https://github.com/apache/pulsar/pull/12016#discussion_r706846391 ## File path: pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java ## @@ -293,6 +297,11 @@ public static void main(Str

[GitHub] [pulsar] gaoran10 commented on a change in pull request #12016: [testclient] Add new option --num-messages for consumer and reader

gaoran10 commented on a change in pull request #12016: URL: https://github.com/apache/pulsar/pull/12016#discussion_r706846391 ## File path: pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java ## @@ -293,6 +297,11 @@ public static void main(Str

[GitHub] [pulsar] MarvinCai commented on a change in pull request #11986: [pulsar admin] getPartitionedTopicMetada method support setting auto create topic

MarvinCai commented on a change in pull request #11986: URL: https://github.com/apache/pulsar/pull/11986#discussion_r706825383 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java ## @@ -786,6 +786,9 @@ public PartitionedTopicMetada

[GitHub] [pulsar] yuruguo commented on pull request #12016: [testclient] Add new option --num-messages for consumer and reader

yuruguo commented on pull request #12016: URL: https://github.com/apache/pulsar/pull/12016#issuecomment-917624701 PTAL @merlimat @eolivelli @lhotari @codelipenghui @hangc0276 @315157973 @gaoran10 THX! -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [pulsar] yuruguo opened a new pull request #12016: [testclient] Add new option --num-messages for consumer and reader

yuruguo opened a new pull request #12016: URL: https://github.com/apache/pulsar/pull/12016 ### Motivation Add new option `--num-messages` for a `consumer` and `reader` in pulsar-perf, and allow users to set the number of messages to consume in total. ### Modifications - Add new

[GitHub] [pulsar] yuruguo edited a comment on pull request #11980: [doc] Update cli-tools document

yuruguo edited a comment on pull request #11980: URL: https://github.com/apache/pulsar/pull/11980#issuecomment-917537006 > Currently, after pulsar 2.8, most of the tools' documentation is automatically generated by the tool, and only a few of them are not yet covered by the automation tool

[GitHub] [pulsar] yuruguo edited a comment on pull request #11980: [doc] Update cli-tools document

yuruguo edited a comment on pull request #11980: URL: https://github.com/apache/pulsar/pull/11980#issuecomment-917537006 > Currently, after pulsar 2.8, most of the tools' documentation is automatically generated by the tool, and only a few of them are not yet covered by the automation tool

[GitHub] [pulsar] eolivelli commented on pull request #12015: Fix update ledger list to znode version mismatch failed, ledger not delete

eolivelli commented on pull request #12015: URL: https://github.com/apache/pulsar/pull/12015#issuecomment-917581704 Good catch I am not sure that this applies to2.7.x -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu