[GitHub] [pulsar] eolivelli commented on pull request #10716: Support using AutoProduceBytesSchema as the function output schema

eolivelli commented on pull request #10716: URL: https://github.com/apache/pulsar/pull/10716#issuecomment-849367491 great stuff. I am happy than now with have msg.getReaderSchema() and we can do this kind of processing -- This is an automated message from the Apache Git Service. To re

[GitHub] [pulsar] complone commented on a change in pull request #10544: [plusar-10479] Resolved Allow Java client to create consumer with rec…

complone commented on a change in pull request #10544: URL: https://github.com/apache/pulsar/pull/10544#discussion_r640314823 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java ## @@ -184,6 +191,50 @@ protected ConsumerBase(PulsarClientIm

[GitHub] [pulsar] BewareMyPower commented on issue #10694: pulsar-admin should print better error message when schema is invalid

BewareMyPower commented on issue #10694: URL: https://github.com/apache/pulsar/issues/10694#issuecomment-849303636 @congbobo184 Could you take a look at this issue? I think it's caused by incorrect combinations of `thenApply` and `exceptionally` as we have discussed before. I found there'

[GitHub] [pulsar] RobertIndie commented on pull request #10685: [Broker] Add multi roles support for authentication and authorization

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

[GitHub] [pulsar] BewareMyPower commented on issue #10721: (2.7.1) Python client blocks forever in "create_producer" during a broker failure, even if "operation_timeout_seconds" is set

BewareMyPower commented on issue #10721: URL: https://github.com/apache/pulsar/issues/10721#issuecomment-849295081 I just found that the TCP connection timeout is not included in operation timeout. I'm not sure what's your state of connection between the blocked client and its associated b

[GitHub] [pulsar] BewareMyPower edited a comment on issue #10721: (2.7.1) Python client blocks forever in "create_producer" during a broker failure, even if "operation_timeout_seconds" is set

BewareMyPower edited a comment on issue #10721: URL: https://github.com/apache/pulsar/issues/10721#issuecomment-849272153 `create_producer` will first connect to the URL's broker for topic lookup. Currently C++/Python client only supports a single broker's advertised address, which broker

[GitHub] [pulsar] RobertIndie commented on a change in pull request #10685: [Broker] Add multi roles support for authentication and authorization

RobertIndie commented on a change in pull request #10685: URL: https://github.com/apache/pulsar/pull/10685#discussion_r640251663 ## File path: pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProvider.java ## @@ -66,6 +69,10 @@ default S

[GitHub] [pulsar] BewareMyPower commented on issue #10721: (2.7.1) Python client blocks forever in "create_producer" during a broker failure, even if "operation_timeout_seconds" is set

BewareMyPower commented on issue #10721: URL: https://github.com/apache/pulsar/issues/10721#issuecomment-849272153 `create_producer` will first connect to the URL's broker for topic lookup. Currently C++/Python client only supports a single broker's advertised address, which broker did you

[GitHub] [pulsar] yangl commented on a change in pull request #10715: ZkIsolatedBookieEnsemblePlacementPolicy should use bookie zookeeper

yangl commented on a change in pull request #10715: URL: https://github.com/apache/pulsar/pull/10715#discussion_r640246494 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java ## @@ -92,6 +96,36 @@ protected ZooKeeperCache localZkCache()

[pulsar] branch master updated (2cfed8c -> 4b86c26)

This is an automated email from the ASF dual-hosted git repository. bogong pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 2cfed8c MINOR: Add error message to setMaxPendingMessagesAcrossPartitions (#10709) add 4b86c26 [Transaction]

[GitHub] [pulsar] congbobo184 merged pull request #10701: [Transaction] Transaction admin api get slow transaction metadata.

congbobo184 merged pull request #10701: URL: https://github.com/apache/pulsar/pull/10701 -- 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, p

[GitHub] [pulsar] rdhabalia commented on a change in pull request #10715: ZkIsolatedBookieEnsemblePlacementPolicy should use bookie zookeeper

rdhabalia commented on a change in pull request #10715: URL: https://github.com/apache/pulsar/pull/10715#discussion_r640230286 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java ## @@ -92,6 +96,36 @@ protected ZooKeeperCache localZkCach

[GitHub] [pulsar] rdhabalia commented on a change in pull request #10715: ZkIsolatedBookieEnsemblePlacementPolicy should use bookie zookeeper

rdhabalia commented on a change in pull request #10715: URL: https://github.com/apache/pulsar/pull/10715#discussion_r640229889 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataSetup.java ## @@ -224,10 +229,22 @@ public static void main(String[]

[GitHub] [pulsar] sijie commented on a change in pull request #10711: [Transaction] Fix transaction log handle managed ledger WriteFail state.

sijie commented on a change in pull request #10711: URL: https://github.com/apache/pulsar/pull/10711#discussion_r640225117 ## File path: managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryImpl.java ## @@ -324,10 +324,10 @@ public void asyncOpen

[pulsar] branch master updated (894d92b -> 2cfed8c)

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 894d92b [broker] Fix issue where StackOverflowError occurs when trying to redeliver a large number of already acked

[GitHub] [pulsar] sijie merged pull request #10709: MINOR: Add error message to setMaxPendingMessagesAcrossPartitions

sijie merged pull request #10709: URL: https://github.com/apache/pulsar/pull/10709 -- 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

[pulsar] branch master updated (4b2c673 -> 894d92b)

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 4b2c673 Fix inconsistent behavior in LongPairRangeSet (#10713) add 894d92b [broker] Fix issue where StackOverfl

[GitHub] [pulsar] sijie merged pull request #10696: [broker] Fix issue where StackOverflowError occurs when trying to redeliver a large number of already acked messages

sijie merged pull request #10696: URL: https://github.com/apache/pulsar/pull/10696 -- 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

[GitHub] [pulsar] yangl commented on pull request #10715: ZkIsolatedBookieEnsemblePlacementPolicy should use bookie zookeeper

yangl commented on pull request #10715: URL: https://github.com/apache/pulsar/pull/10715#issuecomment-849241211 > can you please add some tests that demonstrate the problem and will prevent regressions in the future ? Okay, I'll do this in the next few days. -- This is an automat

[GitHub] [pulsar] congbobo184 commented on pull request #10711: [Transaction] Fix transaction log handle managed ledger WriteFail state.

congbobo184 commented on pull request #10711: URL: https://github.com/apache/pulsar/pull/10711#issuecomment-849237752 @Anonymitaet This is not needed -- 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

[GitHub] [pulsar] sijie commented on issue #10693: Support config remote clusters' TLS settings for geo-replicator

sijie commented on issue #10693: URL: https://github.com/apache/pulsar/issues/10693#issuecomment-849216648 @linlinnn We need to keep the former logic for backward compatibility. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [pulsar] Anonymitaet commented on pull request #10711: [Transaction] Fix transaction log handle managed ledger WriteFail state.

Anonymitaet commented on pull request #10711: URL: https://github.com/apache/pulsar/pull/10711#issuecomment-849205014 @congbobo184 does this need to add docs? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

[GitHub] [pulsar] zbentley opened a new issue #10721: (2.7.1) Python client blocks forever in "create_producer" during a broker failure, even if "operation_timeout_seconds" is set

zbentley opened a new issue #10721: URL: https://github.com/apache/pulsar/issues/10721 **Describe the bug** During some chaos testing of a Pulsar cluster I observed a case in which the Python client does not honor the "operation_timeout_secs" timeout field and blocks forever while t

[GitHub] [pulsar] david-streamlio opened a new issue #10720: pulsar-admin functions update drops user-configs

david-streamlio opened a new issue #10720: URL: https://github.com/apache/pulsar/issues/10720 **Describe the bug** When using the /pulsar-admin functions update command to update an existing function instance. If you only provide the `--parallelism` flag, then the previously provided us

[GitHub] [pulsar] hanguyen6 opened a new issue #10719: k8s: connect to proxy URL return HTTP 502 503 error after broker restart

hanguyen6 opened a new issue #10719: URL: https://github.com/apache/pulsar/issues/10719 **Describe the bug** We connect to Pulsar brokers via proxy URL and observe that after Pulsar brokers restart (due to Out-of-Memory) requests for Pulsar schemas return "503 Service Unavailable "

[GitHub] [pulsar] frankjkelly commented on issue #8922: Infinite reconnections (with error) when authentication fails on Java client

frankjkelly commented on issue #8922: URL: https://github.com/apache/pulsar/issues/8922#issuecomment-849014939 Any chance this is related to https://github.com/apache/pulsar/issues/7927 - at least insofar as the reconnections bit? -- This is an automated message from the Apache Git Servi

[GitHub] [pulsar] Alxander64 opened a new issue #10718: Broker Settings Under Wrong Section

Alxander64 opened a new issue #10718: URL: https://github.com/apache/pulsar/issues/10718 **Describe the bug** In the section of broker.conf titled [Replication](https://github.com/apache/pulsar/blob/master/conf/broker.conf#L1080), there are a few settings that seem out of place.

[pulsar] branch master updated (772a888 -> 4b2c673)

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 772a888 [Doc] Add descriptions for managed cursor acknowledgment state (2.7.3) (#10714) add 4b2c673 Fix incon

[GitHub] [pulsar] merlimat merged pull request #10713: Fix inconsistent behavior in LongPairRangeSet

merlimat merged pull request #10713: URL: https://github.com/apache/pulsar/pull/10713 -- 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, plea

[GitHub] [pulsar] MichalKoziorowski-TomTom commented on issue #10717: [Java][Client] 2.7.2 regression. MultiTopicsConsumer org.apache.pulsar.client.api.PulsarClientException$NotSupportedException: no

MichalKoziorowski-TomTom commented on issue #10717: URL: https://github.com/apache/pulsar/issues/10717#issuecomment-848977951 I guess that issue can be somehow related to that change: https://github.com/apache/pulsar/pull/9660 -- This is an automated message from the Apache Git Service.

[GitHub] [pulsar] MichalKoziorowski-TomTom opened a new issue #10717: [Pulsar Java Client] 2.7.2 regression. MultiTopicsConsumer org.apache.pulsar.client.api.PulsarClientException$NotSupportedExcepti

MichalKoziorowski-TomTom opened a new issue #10717: URL: https://github.com/apache/pulsar/issues/10717 **Describe the bug** After upgrading java client to 2.7.2 version we started to notice following logs: ``` 2021-05-26 18:00:39.236 ERROR 11646 --- [r-client-io-1-1] o.a.p.c.impl.

[GitHub] [pulsar] devinbost edited a comment on issue #6054: Catastrophic frequent random subscription freezes, especially on high-traffic topics.

devinbost edited a comment on issue #6054: URL: https://github.com/apache/pulsar/issues/6054#issuecomment-848968627 Many thanks to @lhotari for figuring out how to reproduce this bug outside of my environment. -- This is an automated message from the Apache Git Service. To respond to th

[GitHub] [pulsar] devinbost commented on issue #6054: Catastrophic frequent random subscription freezes, especially on high-traffic topics.

devinbost commented on issue #6054: URL: https://github.com/apache/pulsar/issues/6054#issuecomment-848968627 Many thanks to @lhotari for figuring out how to reproduce this bug. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [pulsar] devinbost commented on issue #6054: Catastrophic frequent random subscription freezes, especially on high-traffic topics.

devinbost commented on issue #6054: URL: https://github.com/apache/pulsar/issues/6054#issuecomment-848967270 We discovered that certain non-default broker.conf settings seem to be key to reproducing this bug, but we haven't yet identified which of them are responsible. ``` maxUn

[GitHub] [pulsar] michaeljmarshall commented on a change in pull request #7355: Handling error in creation of non-durable cursor

michaeljmarshall commented on a change in pull request #7355: URL: https://github.com/apache/pulsar/pull/7355#discussion_r639953231 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java ## @@ -688,12 +688,13 @@ public void o

[GitHub] [pulsar] BewareMyPower commented on a change in pull request #10712: [C++] Add C++ example for customizing the logger factory

BewareMyPower commented on a change in pull request #10712: URL: https://github.com/apache/pulsar/pull/10712#discussion_r639923788 ## File path: pulsar-client-cpp/examples/SampleFileLogger.cc ## @@ -0,0 +1,111 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under o

[GitHub] [pulsar] BewareMyPower commented on a change in pull request #10712: [C++] Add C++ example for customizing the logger factory

BewareMyPower commented on a change in pull request #10712: URL: https://github.com/apache/pulsar/pull/10712#discussion_r639923788 ## File path: pulsar-client-cpp/examples/SampleFileLogger.cc ## @@ -0,0 +1,111 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under o

[GitHub] [pulsar] merlimat commented on a change in pull request #10712: [C++] Add C++ example for customizing the logger factory

merlimat commented on a change in pull request #10712: URL: https://github.com/apache/pulsar/pull/10712#discussion_r639917361 ## File path: pulsar-client-cpp/examples/SampleFileLogger.cc ## @@ -0,0 +1,111 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one +

[GitHub] [pulsar] gaoran10 opened a new pull request #10716: Support using AutoProduceBytesSchema as the function output schema

gaoran10 opened a new pull request #10716: URL: https://github.com/apache/pulsar/pull/10716 ### Motivation *Explain here the context, and why you're making that change. What is the problem you're trying to solve.* ### Modifications *Describe the modifications you've

[GitHub] [pulsar] MarvinCai commented on issue #10621: Negative acknowledgement number of retries

MarvinCai commented on issue #10621: URL: https://github.com/apache/pulsar/issues/10621#issuecomment-848895477 If retry is enabled a default QLD will be created even if one is not configured. Retry count can be set with ``` DeadLetterPolicy.builder() .maxRedeliverCount(count)

[GitHub] [pulsar] merlimat commented on a change in pull request #10708: On multi-topic consumer, we shouldn't keep checking the partitioned metadata

merlimat commented on a change in pull request #10708: URL: https://github.com/apache/pulsar/pull/10708#discussion_r639869189 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java ## @@ -955,7 +955,7 @@ private void doSubscribeTop

[GitHub] [pulsar] MarvinCai commented on a change in pull request #10707: force to refresh partition metadata info

MarvinCai commented on a change in pull request #10707: URL: https://github.com/apache/pulsar/pull/10707#discussion_r639808851 ## File path: pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/BaseResources.java ## @@ -86,6 +86,13 @@ public BaseResources(Meta

[GitHub] [pulsar] MarvinCai commented on a change in pull request #10707: force to refresh partition metadata info

MarvinCai commented on a change in pull request #10707: URL: https://github.com/apache/pulsar/pull/10707#discussion_r639808851 ## File path: pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/BaseResources.java ## @@ -86,6 +86,13 @@ public BaseResources(Meta

[pulsar] branch master updated (c2e5ec6 -> 772a888)

This is an automated email from the ASF dual-hosted git repository. penghui pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from c2e5ec6 AutoConsumeSchema: use decode(payload, schemaversion) (#10700) add 772a888 [Doc] Add descriptions for

[GitHub] [pulsar] codelipenghui merged pull request #10714: [Doc] Add descriptions for managed cursor acknowledgment state (2.7.3)

codelipenghui merged pull request #10714: URL: https://github.com/apache/pulsar/pull/10714 -- 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,

[GitHub] [pulsar] codelipenghui commented on a change in pull request #10710: [issue 10693] use unify configuration from remote cluster for geo-replicator

codelipenghui commented on a change in pull request #10710: URL: https://github.com/apache/pulsar/pull/10710#discussion_r639785017 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java ## @@ -1029,21 +1029,19 @@ public PulsarClient getRe

[GitHub] [pulsar] cckellogg commented on a change in pull request #10685: [Broker] Add multi roles support for authentication and authorization

cckellogg commented on a change in pull request #10685: URL: https://github.com/apache/pulsar/pull/10685#discussion_r639732409 ## File path: pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProvider.java ## @@ -66,6 +69,10 @@ default Str

[GitHub] [pulsar] cckellogg commented on a change in pull request #10685: [Broker] Add multi roles support for authentication and authorization

cckellogg commented on a change in pull request #10685: URL: https://github.com/apache/pulsar/pull/10685#discussion_r639732409 ## File path: pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProvider.java ## @@ -66,6 +69,10 @@ default Str

[GitHub] [pulsar] codelipenghui commented on pull request #8026: [pulsar-functions] Fix message consume ordering issue of function

codelipenghui commented on pull request #8026: URL: https://github.com/apache/pulsar/pull/8026#issuecomment-848796797 @Tiscs Yes, it should be closed. -- 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

[GitHub] [pulsar] codelipenghui closed issue #7707: I am testing the pulsar function when Processing guarantees is set to EFFECTIVELY_ONCE and found that the function will not automatically terminate

codelipenghui closed issue #7707: URL: https://github.com/apache/pulsar/issues/7707 -- 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

[GitHub] [pulsar] cckellogg commented on a change in pull request #10685: [Broker] Add multi roles support for authentication and authorization

cckellogg commented on a change in pull request #10685: URL: https://github.com/apache/pulsar/pull/10685#discussion_r639732409 ## File path: pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProvider.java ## @@ -66,6 +69,10 @@ default Str

[GitHub] [pulsar] cckellogg commented on a change in pull request #10685: [Broker] Add multi roles support for authentication and authorization

cckellogg commented on a change in pull request #10685: URL: https://github.com/apache/pulsar/pull/10685#discussion_r639707307 ## File path: pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/OneStageAuthenticationState.java ## @@ -35,20 +38,36 @@ publ

[GitHub] [pulsar] zymap commented on issue #10692: pulsar-bookie and pulsar-broker CrashLoopBackOff in kubernetes

zymap commented on issue #10692: URL: https://github.com/apache/pulsar/issues/10692#issuecomment-848746897 Yes. It should fix the issue. -- 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 spec

[GitHub] [pulsar] 315157973 commented on a change in pull request #10713: Fix inconsistent behavior in LongPairRangeSet

315157973 commented on a change in pull request #10713: URL: https://github.com/apache/pulsar/pull/10713#discussion_r639667409 ## File path: pulsar-common/src/test/java/org/apache/pulsar/common/util/collections/DefaultRangeSetTest.java ## @@ -0,0 +1,57 @@ +/** + * Licensed to

[pulsar-manager] branch master updated (09a9781 -> 8eb98c9)

This is an automated email from the ASF dual-hosted git repository. guangning pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-manager.git. from 09a9781 fix unload namespace error (#386) add 8eb98c9 fix ISSUE-390: Pulsar manager successfully ad

[pulsar-manager] branch master updated: Use the Apache Pulsar Helm chart (#384)

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 4796f0c Use the Apache Pulsar Helm c

[GitHub] [pulsar] eolivelli commented on a change in pull request #10713: Fix inconsistent behavior in LongPairRangeSet

eolivelli commented on a change in pull request #10713: URL: https://github.com/apache/pulsar/pull/10713#discussion_r639641076 ## File path: pulsar-common/src/test/java/org/apache/pulsar/common/util/collections/DefaultRangeSetTest.java ## @@ -0,0 +1,57 @@ +/** + * Licensed to

[GitHub] [pulsar] yangl opened a new pull request #10715: ZkIsolatedBookieEnsemblePlacementPolicy should use bookie zookeeper

yangl opened a new pull request #10715: URL: https://github.com/apache/pulsar/pull/10715 ### Motivation Since the current ZkIsolatedBookieEnsemblePlacementPolicy rack configuration metadata is stored on the zookeeper cluster where the broker is located, this causes the bookkeeper t

[GitHub] [pulsar] Anonymitaet opened a new pull request #10714: [Doc] Add descriptions for managed cursor acknowledgment state (2.7.3)

Anonymitaet opened a new pull request #10714: URL: https://github.com/apache/pulsar/pull/10714 Same to https://github.com/apache/pulsar/pull/10695 -- 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

[GitHub] [pulsar] jiazhai commented on pull request #10670: [Issue 10669] Add Pulsar_GC_LOG when start broker with bin/pulsar

jiazhai commented on pull request #10670: URL: https://github.com/apache/pulsar/pull/10670#issuecomment-848631508 /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

[pulsar] branch branch-2.7 updated: Update version to 2.7.3-SNAPSHOT

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch branch-2.7 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-2.7 by this push: new bc6668b Update version to 2.7.3-SNAP

[GitHub] [pulsar] vanmeete commented on issue #10702: [Pulsar IO] In Sink connector, record.getSchema(); returns null when processing from partitioned topic.

vanmeete commented on issue #10702: URL: https://github.com/apache/pulsar/issues/10702#issuecomment-848581888 The issue does not occur in 2.8.0-SNAPSHOT -- 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] 315157973 opened a new pull request #10713: Fix inconsistent behavior in LongPairRangeSet

315157973 opened a new pull request #10713: URL: https://github.com/apache/pulsar/pull/10713 ### Motivation Now `LongPairRangeSet` has two implementation classes: ConcurrentOpenLongPairRangeSet and DefaultRangeSet But their behavior in some methods is inconsistent, such as: firstRange

[pulsar] branch master updated (3b504d0 -> c2e5ec6)

This is an automated email from the ASF dual-hosted git repository. penghui pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 3b504d0 [Transactionn] Transaction admin api getTransactionBufferStatus and getPendingAckStatus (#10650) add

[GitHub] [pulsar] codelipenghui merged pull request #10700: AutoConsumeSchema: use decode(payload, schemaversion)

codelipenghui merged pull request #10700: URL: https://github.com/apache/pulsar/pull/10700 -- 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,

[pulsar] branch master updated (6ab493c -> 3b504d0)

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 6ab493c Fix NPE when filtering read entries (#10704) add 3b504d0 [Transactionn] Transaction admin api getT

[GitHub] [pulsar] eolivelli merged pull request #10650: [Transactionn] Transaction admin api getTransactionBufferStatus and getPendingAckStatus

eolivelli merged pull request #10650: URL: https://github.com/apache/pulsar/pull/10650 -- 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, ple

[GitHub] [pulsar] codelipenghui commented on pull request #10491: [Functions] Adding “numListenerThreads” configuration parameter in WorkerConfig . #8575

codelipenghui commented on pull request #10491: URL: https://github.com/apache/pulsar/pull/10491#issuecomment-848571587 @xche Could you please help check the failed tests? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[GitHub] [pulsar] codelipenghui commented on a change in pull request #10711: [Transaction] Fix transaction log handle managed ledger WriteFail state.

codelipenghui commented on a change in pull request #10711: URL: https://github.com/apache/pulsar/pull/10711#discussion_r639496319 ## File path: managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java ## @@ -215,7 +215,7 @@ protected static

[GitHub] [pulsar] codelipenghui commented on a change in pull request #10650: [Transactionn] Transaction admin api getTransactionBufferStatus and getPendingAckStatus

codelipenghui commented on a change in pull request #10650: URL: https://github.com/apache/pulsar/pull/10650#discussion_r639493159 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v3/Transactions.java ## @@ -55,6 +55,55 @@ public void getCoordinatorStat

[GitHub] [pulsar] codelipenghui commented on pull request #10650: [Transactionn] Transaction admin api component in topic status

codelipenghui commented on pull request #10650: URL: https://github.com/apache/pulsar/pull/10650#issuecomment-848553437 @congbobo184 Could you please update the title of the PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [pulsar] codelipenghui commented on a change in pull request #10701: [Transaction] Transaction admin api get slow transaction metadata.

codelipenghui commented on a change in pull request #10701: URL: https://github.com/apache/pulsar/pull/10701#discussion_r639473305 ## File path: pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTransactions.java ## @@ -95,11 +97,34 @@ void run() throws Exceptio

[GitHub] [pulsar] BewareMyPower opened a new pull request #10712: [C++] Add SampleFileLogger C++ example

BewareMyPower opened a new pull request #10712: URL: https://github.com/apache/pulsar/pull/10712 ### Motivation Some users are confused about how to customize the logger in C++ client, while they don't want to build their own cpp library with log4cxx support and change the log4cxx.

[GitHub] [pulsar] congbobo184 opened a new pull request #10711: [Transaction] Fix transaction log handle managed ledger WriteFail state.

congbobo184 opened a new pull request #10711: URL: https://github.com/apache/pulsar/pull/10711 ## Motivation when transaction log managed ledger state become WriteFailed state, should `readyToCreateNewLedger`. ## implement append fail check the managedLedger state and the e

[GitHub] [pulsar] codelipenghui merged pull request #10704: Fix NPE when filtering read entries

codelipenghui merged pull request #10704: URL: https://github.com/apache/pulsar/pull/10704 -- 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,

[pulsar] branch master updated (e0fef93 -> 6ab493c)

This is an automated email from the ASF dual-hosted git repository. penghui pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from e0fef93 Add 2.7.3 docs for repo (#10666) add 6ab493c Fix NPE when filtering read entries (#10704) No new rev