[GitHub] [pulsar] dlg99 commented on a change in pull request #10498: SinkContext: ability to seek/pause/resume consumer for a topic

dlg99 commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r632323145 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void close() {

[GitHub] [pulsar] dlg99 commented on a change in pull request #10498: SinkContext: ability to seek/pause/resume consumer for a topic

dlg99 commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r632325403 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void close() {

[GitHub] [pulsar] lhotari merged pull request #10581: Update vcpkg.json package list

lhotari merged pull request #10581: URL: https://github.com/apache/pulsar/pull/10581 -- 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 (79757ac -> 959a8c8)

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 79757ac Update vcpkg.json package list (#10581) add 959a8c8 Show 2.7.2 release on WebSite (#10585) No new

[GitHub] [pulsar] eolivelli merged pull request #10585: Show 2.7.2 release on WebSite

eolivelli merged pull request #10585: URL: https://github.com/apache/pulsar/pull/10585 -- 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] Anonymitaet commented on a change in pull request #10540: Apache Pulsar 2.7.2 blog page

Anonymitaet commented on a change in pull request #10540: URL: https://github.com/apache/pulsar/pull/10540#discussion_r632361580 ## File path: site2/website/blog/2021-05-13-Apache-Pulsar-2-7-2.md ## @@ -0,0 +1,68 @@ +--- +author: Enrico Olivelli +authorURL:

[GitHub] [pulsar] eolivelli commented on a change in pull request #10540: Apache Pulsar 2.7.2 blog page

eolivelli commented on a change in pull request #10540: URL: https://github.com/apache/pulsar/pull/10540#discussion_r632372904 ## File path: site2/website/blog/2021-05-13-Apache-Pulsar-2-7-2.md ## @@ -0,0 +1,68 @@ +--- +author: Enrico Olivelli +authorURL:

[GitHub] [pulsar] BewareMyPower commented on a change in pull request #10586: Fix NPE when ACK grouping tracker checks duplicated message id

BewareMyPower commented on a change in pull request #10586: URL: https://github.com/apache/pulsar/pull/10586#discussion_r632372675 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageIdImpl.java ## @@ -210,7 +210,8 @@ public int compareTo(MessageId

[GitHub] [pulsar] eolivelli commented on issue #10582: Unable to build RPM packages

eolivelli commented on issue #10582: URL: https://github.com/apache/pulsar/issues/10582#issuecomment-841042755 thank you very much for reporting this issue, it is very useful, as we are going to cut 2.8.0 soon. I am adding "blocker" label -- This is an automated message from the

[GitHub] [pulsar] eolivelli commented on pull request #10540: Apache Pulsar 2.7.2 blog page

eolivelli commented on pull request #10540: URL: https://github.com/apache/pulsar/pull/10540#issuecomment-841086039 -- 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

[GitHub] [pulsar] eolivelli commented on a change in pull request #10586: Fix NPE when ACK grouping tracker checks duplicated message id

eolivelli commented on a change in pull request #10586: URL: https://github.com/apache/pulsar/pull/10586#discussion_r632365085 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageIdImpl.java ## @@ -210,7 +210,8 @@ public int compareTo(MessageId o) {

[GitHub] [pulsar] eolivelli commented on pull request #10384: [Broker] Fix various issues when using preciseTopicPublishRateLimiterEnable=true

eolivelli commented on pull request #10384: URL: https://github.com/apache/pulsar/pull/10384#issuecomment-841094967 @codelipenghui @merlimat @rdhabalia do you have any comment ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [pulsar] abhilashmandaliya opened a new issue #10587: Support alias for the Schema and Message

abhilashmandaliya opened a new issue #10587: URL: https://github.com/apache/pulsar/issues/10587 Schema and message should support different names/alias while performing SerDe. Like `ObjectMapper` has `@JsonAlias` and `@JsonProperty`. Probably we can use the same feature as Pulsar Schemas

[GitHub] [pulsar] eolivelli commented on a change in pull request #10498: SinkContext: ability to seek/pause/resume consumer for a topic

eolivelli commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r632314094 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void

[pulsar] branch master updated: Update vcpkg.json package list (#10581)

This is an automated email from the ASF dual-hosted git repository. lhotari 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 79757ac Update vcpkg.json package list

[GitHub] [pulsar] eolivelli commented on a change in pull request #10498: SinkContext: ability to seek/pause/resume consumer for a topic

eolivelli commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r632333045 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void

[GitHub] [pulsar] BewareMyPower opened a new pull request #10586: Fix NPE when ACK grouping tracker checks duplicated message id

BewareMyPower opened a new pull request #10586: URL: https://github.com/apache/pulsar/pull/10586 ### Motivation Recently I encountered the following NPE but it's hard to reproduce. ``` 01:40:14.630 [pulsar-client-io-54-1] WARN org.apache.pulsar.client.impl.ClientCnx -

[GitHub] [pulsar] eolivelli commented on pull request #10573: [Schema] Add schemaType field in SchemaHash

eolivelli commented on pull request #10573: URL: https://github.com/apache/pulsar/pull/10573#issuecomment-841092101 @gaoran10 can you please take a look to integration tests? I have never seen this failure before, it is probably not a flaky test but a problem with this patch

[GitHub] [pulsar] eolivelli commented on a change in pull request #10540: Apache Pulsar 2.7.2 blog page

eolivelli commented on a change in pull request #10540: URL: https://github.com/apache/pulsar/pull/10540#discussion_r632371762 ## File path: site2/website/blog/2021-05-13-Apache-Pulsar-2-7-2.md ## @@ -0,0 +1,68 @@ +--- +author: Enrico Olivelli +authorURL:

[GitHub] [pulsar] baomingyu commented on pull request #10285: fix issue 10284 Occasional consumer stucked when restart consumer whit key_shared subscription type

baomingyu commented on pull request #10285: URL: https://github.com/apache/pulsar/pull/10285#issuecomment-841040586 /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

[GitHub] [pulsar] eolivelli commented on pull request #10285: fix issue 10284 Occasional consumer stucked when restart consumer whit key_shared subscription type

eolivelli commented on pull request #10285: URL: https://github.com/apache/pulsar/pull/10285#issuecomment-841043528 @baomingyu thanks for your contribution I see that there are lot of formatting changes, can you please revert all of the changes that are not needed in order to fix

[GitHub] [pulsar] eolivelli commented on a change in pull request #10498: SinkContext: ability to seek/pause/resume consumer for a topic

eolivelli commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r632332932 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void

[GitHub] [pulsar] Anonymitaet commented on issue #10584: broker.conf documentation : wrong tokenSecretKey base64 inline description

Anonymitaet commented on issue #10584: URL: https://github.com/apache/pulsar/issues/10584#issuecomment-841079005 Hi @daniel-bartz have you tried `tokenSecretKey=data:;base64,**`? (with the semicolon) -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [pulsar-client-go] cydrain commented on issue #516: pulsar RACE issue

cydrain commented on issue #516: URL: https://github.com/apache/pulsar-client-go/issues/516#issuecomment-841115685 Any update ? -- 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

[GitHub] [pulsar] MichealJou opened a new issue #10588: When to support the springboot ecosystem

MichealJou opened a new issue #10588: URL: https://github.com/apache/pulsar/issues/10588 When to support the springboot ecosystem -- 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

[pulsar-helm-chart] branch release/update-272 created (now 3929f0d)

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a change to branch release/update-272 in repository https://gitbox.apache.org/repos/asf/pulsar-helm-chart.git. at 3929f0d Update to Pulsar 2.7.2 No new revisions were added by this update.

[GitHub] [pulsar] baomingyu commented on pull request #10285: fix issue 10284 Occasional consumer stucked when restart consumer whit key_shared subscription type

baomingyu commented on pull request #10285: URL: https://github.com/apache/pulsar/pull/10285#issuecomment-841065333 @eolivellihas done，please review this change. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [pulsar] eolivelli opened a new pull request #10585: Show 2.7.2 release on WebSite

eolivelli opened a new pull request #10585: URL: https://github.com/apache/pulsar/pull/10585 -- 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

[GitHub] [pulsar] lhotari commented on a change in pull request #10384: [Broker] Fix various issues when using preciseTopicPublishRateLimiterEnable=true

lhotari commented on a change in pull request #10384: URL: https://github.com/apache/pulsar/pull/10384#discussion_r632344627 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java ## @@ -425,6 +425,13 @@ public void

[GitHub] [pulsar] lhotari commented on a change in pull request #10384: [Broker] Fix various issues when using preciseTopicPublishRateLimiterEnable=true

lhotari commented on a change in pull request #10384: URL: https://github.com/apache/pulsar/pull/10384#discussion_r632344868 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PrecisPublishLimiter.java ## @@ -71,31 +80,63 @@ public void update(Policies

[GitHub] [pulsar] eolivelli commented on a change in pull request #10586: Fix NPE when ACK grouping tracker checks duplicated message id

eolivelli commented on a change in pull request #10586: URL: https://github.com/apache/pulsar/pull/10586#discussion_r632365085 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageIdImpl.java ## @@ -210,7 +210,8 @@ public int compareTo(MessageId o) {

[GitHub] [pulsar] eolivelli commented on a change in pull request #10540: Apache Pulsar 2.7.2 blog page

eolivelli commented on a change in pull request #10540: URL: https://github.com/apache/pulsar/pull/10540#discussion_r632373985 ## File path: site2/website/blog/2021-05-13-Apache-Pulsar-2-7-2.md ## @@ -0,0 +1,68 @@ +--- +author: Enrico Olivelli +authorURL:

[GitHub] [pulsar] eolivelli commented on a change in pull request #10428: [Issue #10427] Add AvroSchema UUID support fix

eolivelli commented on a change in pull request #10428: URL: https://github.com/apache/pulsar/pull/10428#discussion_r632409675 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/util/SchemaUtil.java ## @@ -88,8 +90,10 @@ public static Schema

[GitHub] [pulsar] eolivelli commented on issue #10587: Support alias for the Schema and Message

eolivelli commented on issue #10587: URL: https://github.com/apache/pulsar/issues/10587#issuecomment-841147221 I see your problem. but we have to find some way in order to abstract from Jackson Mapper because relying on Jackson Mapper will add an hard dependency for Pulsar.

[GitHub] [pulsar] tuteng commented on issue #10588: When to support the springboot ecosystem

tuteng commented on issue #10588: URL: https://github.com/apache/pulsar/issues/10588#issuecomment-841149214 One community example https://github.com/majusko/pulsar-java-spring-boot-starter -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [pulsar] daniel-bartz commented on issue #10584: broker.conf documentation : wrong tokenSecretKey base64 inline description

daniel-bartz commented on issue #10584: URL: https://github.com/apache/pulsar/issues/10584#issuecomment-841174356 @Anonymitaet Yes, I tried it and it did not work for me with the semicolon. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [pulsar] BewareMyPower commented on pull request #10586: Fix NPE when ACK grouping tracker checks duplicated message id

BewareMyPower commented on pull request #10586: URL: https://github.com/apache/pulsar/pull/10586#issuecomment-841178616 Now all tests passed, PTAL again @eolivelli -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [pulsar] KannarFr commented on pull request #8048: [Issue 7903][proxy]Enable AutoTopicCreationType partitioned through proxy

KannarFr commented on pull request #8048: URL: https://github.com/apache/pulsar/pull/8048#issuecomment-841179075 @rudy2steiner can you clean rebase from `pulsar:master`? The tests are failing in `PulsarFunctionsProcessTest` and this file no more exists in `apache:master`. -- This is an

[pulsar] 05/14: Remove solr

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch 2.7.2_ds_rootless in repository https://gitbox.apache.org/repos/asf/pulsar.git commit cfadf050bbb5adde2d01518affe98c98f4a4a9c4 Author: Enrico Olivelli AuthorDate: Thu May 13 15:50:16 2021

[pulsar] 04/14: Remove Solr

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch 2.7.2_ds_rootless in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 53120ffa6799fc4b9883572b8f8d286856db0244 Author: Enrico Olivelli AuthorDate: Thu May 13 14:26:10 2021

[pulsar] 07/14: Fix KeyStoreTlsTest on JDK11 (#10345)

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch 2.7.2_ds_rootless in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 8c3787fadc7813c6e2875b20c2b9793315bf8186 Author: Lari Hotari AuthorDate: Mon Apr 26 00:57:41 2021 +0300

[pulsar] 08/14: [Tests] Fix ProxyWithAuthorizationTest on JDK11 (#10346)

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch 2.7.2_ds_rootless in repository https://gitbox.apache.org/repos/asf/pulsar.git commit f17c5d6e8d5d051b6b65cbc0ca187f126faabcf2 Author: Lari Hotari AuthorDate: Fri Apr 23 22:28:52 2021 +0300

[pulsar] 12/14: Revert "Regenerate test certificates in pulsar-broker/src/test/resources/authentication/tls"

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch 2.7.2_ds_rootless in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 0bfe3e03370dc7a17dfcfc5c82e089b81b4e0623 Author: Lari Hotari AuthorDate: Fri May 14 13:05:59 2021 +0300

[pulsar] 09/14: Regenerate test certificates in pulsar-broker/src/test/resources/authentication/tls

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch 2.7.2_ds_rootless in repository https://gitbox.apache.org/repos/asf/pulsar.git commit c96e31f85c0bd5c00f5692cbf61bc8ded330eddc Author: Lari Hotari AuthorDate: Fri May 14 12:19:36 2021 +0300

[pulsar] 06/14: Use Message.getReaderSchema() in Pulsar IO Sinks when possible (#10557)

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch 2.7.2_ds_rootless in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 5dee3ebe51ee44c859c96f580ddad4769b9f0895 Author: Enrico Olivelli AuthorDate: Fri May 14 07:29:53 2021

[pulsar] 11/14: Add AvroSchema UUID support

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch 2.7.2_ds_rootless in repository https://gitbox.apache.org/repos/asf/pulsar.git commit d5aeb665c9d6c11219809a21801fb575b6ee33ed Author: Vincent Royer AuthorDate: Thu Apr 29 00:03:47 2021 +0200

[pulsar] 10/14: [Build] Specify release in maven-compiler-plugin configuration on JDK11 (#10343)

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch 2.7.2_ds_rootless in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 1a94bbcdc7b197f1167652e894de093ab7cf7be2 Author: Lari Hotari AuthorDate: Mon Apr 26 00:56:56 2021 +0300

[pulsar] 13/14: Fix expired tls certs for cpp tests (#9607)

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch 2.7.2_ds_rootless in repository https://gitbox.apache.org/repos/asf/pulsar.git commit feb511d431997c2d821f891a81c4d45193c1bdc8 Author: Sijie Guo AuthorDate: Wed Feb 17 15:55:57 2021 -0800

[pulsar] branch 2.7.2_ds_rootless created (now 376867a)

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a change to branch 2.7.2_ds_rootless in repository https://gitbox.apache.org/repos/asf/pulsar.git. at 376867a [Issue 8751] Update Dockerfile for Pulsar and Dashboard to Create and Use pulsar User

[pulsar] 01/14: Fix build

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch 2.7.2_ds_rootless in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 62624e7ac74ea6dff84989cbab56ce85bc090f78 Author: Enrico Olivelli AuthorDate: Thu May 13 10:01:04 2021

[pulsar] 02/14: [Tests] Recreate keystores used in TLS tests with RSA key algorithm & SHA256 to support JDK 11 & TLS 1.3 (#10336)

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch 2.7.2_ds_rootless in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 47ce9dee6311d0174bd1cf2c05456daa9d9c578f Author: Lari Hotari AuthorDate: Mon Apr 26 20:18:27 2021 +0300

[pulsar] 03/14: Allow to build Pulsar with JDK11 and -Dmaven.compiler.release=8 (#9580)

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch 2.7.2_ds_rootless in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 7e1f9f06f2a4dd031169a8890151eda8042bfc0b Author: Enrico Olivelli AuthorDate: Fri Feb 12 21:55:32 2021

[pulsar] 14/14: [Issue 8751] Update Dockerfile for Pulsar and Dashboard to Create and Use pulsar User (nonroot user) (#8796)

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch 2.7.2_ds_rootless in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 376867a1f9bd729566065e4ca13b1983c426e6f8 Author: Michael Marshall

[GitHub] [pulsar] lhotari opened a new issue #10589: Tests that don't belong to any TestNG group aren't run at all in pulsar-broker module

lhotari opened a new issue #10589: URL: https://github.com/apache/pulsar/issues/10589 **Describe the bug** There are some tests that don't belong to any TestNG group. These tests aren't currently run in CI at all. **To Reproduce**

[GitHub] [pulsar] lhotari opened a new pull request #10590: [Tests] Fix running of all pulsar-broker tests

lhotari opened a new pull request #10590: URL: https://github.com/apache/pulsar/pull/10590 Fixes #10589 ### Motivation See #10589 . Tests that don't belong to any TestNG group aren't run at all in pulsar-broker module. ### Modifications * Add logic to Pulsar's

[GitHub] [pulsar] KannarFr edited a comment on pull request #8048: [Issue 7903][proxy]Enable AutoTopicCreationType partitioned through proxy

KannarFr edited a comment on pull request #8048: URL: https://github.com/apache/pulsar/pull/8048#issuecomment-841179075 @rudy2steiner can you clean rebase from `pulsar:master`? The tests are failing in `PulsarFunctionsProcessTest` and this file no more exists in `pulsar:master`. --

[GitHub] [pulsar] KannarFr edited a comment on pull request #8048: [Issue 7903][proxy]Enable AutoTopicCreationType partitioned through proxy

KannarFr edited a comment on pull request #8048: URL: https://github.com/apache/pulsar/pull/8048#issuecomment-841179075 @rudy2steiner can you clean rebase from `apache:master`? The tests are failing in `PulsarFunctionsProcessTest` in `rudy2steiner:master` and this file no more exists in

[GitHub] [pulsar] lhotari commented on issue #10588: When to support the springboot ecosystem

lhotari commented on issue #10588: URL: https://github.com/apache/pulsar/issues/10588#issuecomment-841150203 btw. there's a feature request #10437 which is related to supporting Spring Reactive. -- This is an automated message from the Apache Git Service. To respond to the message,

[pulsar] branch master updated: Fix NPE when ACK grouping tracker checks duplicated message id (#10586)

This is an automated email from the ASF dual-hosted git repository. eolivelli 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 993ea62 Fix NPE when ACK grouping tracker

[GitHub] [pulsar] eolivelli merged pull request #10586: Fix NPE when ACK grouping tracker checks duplicated message id

eolivelli merged pull request #10586: URL: https://github.com/apache/pulsar/pull/10586 -- 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] eolivelli commented on a change in pull request #7266: [pulsar-broker] Dispatch batch messages according consumer permits

eolivelli commented on a change in pull request #7266: URL: https://github.com/apache/pulsar/pull/7266#discussion_r632765919 ## File path: conf/bkenv.sh ## @@ -39,7 +39,7 @@ BOOKIE_MEM=${BOOKIE_MEM:-${PULSAR_MEM:-"-Xms2g -Xmx2g -XX:MaxDirectMemorySize=2g

[GitHub] [pulsar] Shoothzj opened a new pull request #10595: [Pulsar IO] Develop Huawei Cloud DIS connector

Shoothzj opened a new pull request #10595: URL: https://github.com/apache/pulsar/pull/10595 ### Motivation We are trying to use **Pulsar IO** connector. The **DIS** is one of Sink my business must supported. ### Modifications Add a new **Pulsar IO** module DIS.

[GitHub] [pulsar] david-streamlio opened a new pull request #10593: [Issue-10109] [admin client] Add --batch-source-config switch to the Pulsar Admin Source API

david-streamlio opened a new pull request #10593: URL: https://github.com/apache/pulsar/pull/10593 Fixes #10109 ### Motivation We are unable to create BatchSource connectors using the Pulsar Admin CLI, as there is no way to provide the batch source configuration other than

[GitHub] [pulsar] ta1meng commented on issue #10596: Python client: broken/missing Avro schema support

ta1meng commented on issue #10596: URL: https://github.com/apache/pulsar/issues/10596#issuecomment-841574871 This ticket is a superset of https://github.com/apache/pulsar/issues/9571 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [pulsar] codelipenghui merged pull request #10531: K8s Function Name Length Check Allows Invalid StatefulSet

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

[pulsar] branch master updated (841de89 -> 74c0c31)

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 841de89 [CI] Run pulsar-broker tests that don't belong to any TestNG group (#10590) add 74c0c31 Reduce

[GitHub] [pulsar] codelipenghui merged pull request #10529: Fix partitioned system topic check bug

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

[pulsar] branch master updated: Fix the default retry letter and dead letter topic name (#10129)

This is an automated email from the ASF dual-hosted git repository. penghui 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 86d0830 Fix the default retry letter and dead

[pulsar] branch master updated (96325b9 -> 7bd849b)

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 96325b9 [CLI] Add support for setting time based limit on backlog quota with CLI. (#10401) add 7bd849b

[GitHub] [pulsar] codelipenghui closed issue #9327: Retry and Dead letter topics are generated with wrong names when retry is enabled

codelipenghui closed issue #9327: URL: https://github.com/apache/pulsar/issues/9327 -- 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 merged pull request #10129: fix the default retry letter and dead letter topic name

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

[pulsar] branch master updated: [Issue 3127][python-client] Replace Exceptions with PulsarExceptions (#7600)

This is an automated email from the ASF dual-hosted git repository. penghui 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 3f36544 [Issue 3127][python-client] Replace

[GitHub] [pulsar] codelipenghui merged pull request #7600: [Issue 3127][python-client] Replace Exceptions with PulsarExceptions

codelipenghui merged pull request #7600: URL: https://github.com/apache/pulsar/pull/7600 -- 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] Shoothzj closed pull request #10595: [Pulsar IO] Develop Huawei Cloud DIS connector

Shoothzj closed pull request #10595: URL: https://github.com/apache/pulsar/pull/10595 -- 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] rdhabalia commented on a change in pull request #7266: [pulsar-broker] Dispatch batch messages according consumer permits

rdhabalia commented on a change in pull request #7266: URL: https://github.com/apache/pulsar/pull/7266#discussion_r632844450 ## File path: conf/bkenv.sh ## @@ -39,7 +39,7 @@ BOOKIE_MEM=${BOOKIE_MEM:-${PULSAR_MEM:-"-Xms2g -Xmx2g -XX:MaxDirectMemorySize=2g

[GitHub] [pulsar] ta1meng opened a new issue #10596: Python client: broken/missing Avro schema support

ta1meng opened a new issue #10596: URL: https://github.com/apache/pulsar/issues/10596 **Describe the bug** There are many issues in the Python client library regarding Avro schema support: * The documented

[GitHub] [pulsar] merlimat opened a new pull request #10594: Fixed missed ZK caching when fetching list of namespaces for a tenant

merlimat opened a new pull request #10594: URL: https://github.com/apache/pulsar/pull/10594 ### Motivation The ZK reads triggered by the "get namespaces of a tenant" admin operation are being issued directly on the ZK client and therefore are not getting cached by brokers.

[GitHub] [pulsar] codelipenghui merged pull request #10528: Make failPendingMessages called from within the ProducerImpl object mutex

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

[pulsar] branch master updated (74c0c31 -> 4a8d40c)

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 74c0c31 Reduce function name size to 53 for k8s runtime (#10531) add 4a8d40c Fix partitioned system topic

[GitHub] [pulsar] codelipenghui closed issue #9301: MultiTopicsReaderImpl – Start from separate MessageId for each topic/ partition

codelipenghui closed issue #9301: URL: https://github.com/apache/pulsar/issues/9301 -- 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 merged pull request #10348: Reader support seek from separate messageId/time

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

[pulsar] branch master updated (cd7e3c0 -> 96325b9)

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 cd7e3c0 Make failPendingMessages called from within the ProducerImpl object mutex (#10528) add 96325b9

[GitHub] [pulsar] codelipenghui closed issue #9680: Backlog quota: allow time-based quota

codelipenghui closed issue #9680: URL: https://github.com/apache/pulsar/issues/9680 -- 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 merged pull request #10401: [CLI] Add support for setting time based limit on backlog quota with CLI.

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

[pulsar] branch master updated (4a8d40c -> cd7e3c0)

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 4a8d40c Fix partitioned system topic check bug (#10529) add cd7e3c0 Make failPendingMessages called from

[GitHub] [pulsar] Shoothzj commented on pull request #10595: [Pulsar IO] Develop Huawei Cloud DIS connector

Shoothzj commented on pull request #10595: URL: https://github.com/apache/pulsar/pull/10595#issuecomment-841585081 For the merge policy, I close this PR, I will commit these codes to https://github.com/streamnative/pulsar-io-huawei-dis -- This is an automated message from the Apache Git

[GitHub] [pulsar] codelipenghui commented on pull request #9925: [pulsar-broker] Namespace-resource use namespace name to fetch policy resource

codelipenghui commented on pull request #9925: URL: https://github.com/apache/pulsar/pull/9925#issuecomment-841585101 Hi Rajan @rdhabalia, Could you please help resolve the conflicts? so that we can merge it before 2.8.0 -- This is an automated message from the Apache Git Service. To

[GitHub] [pulsar] eolivelli commented on pull request #7266: [pulsar-broker] Dispatch batch messages according consumer permits

eolivelli commented on pull request #7266: URL: https://github.com/apache/pulsar/pull/7266#issuecomment-841603849 @merlimat do you want to take a look as well? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [pulsar] yangl opened a new pull request #10597: Fix pulsar-client & pulsar-client-admin shaded jar missing code source

yangl opened a new pull request #10597: URL: https://github.com/apache/pulsar/pull/10597 ### Motivation when we use the `pulsar-client` and the `pulsar-client-admin` dependency in the ide(such as the IntelliJ IDEA), which cannot link the code source correctly because of the

[GitHub] [pulsar] eolivelli commented on pull request #10595: [Pulsar IO] Develop Huawei Cloud DIS connector

eolivelli commented on pull request #10595: URL: https://github.com/apache/pulsar/pull/10595#issuecomment-841604321 Can you please explain better this problem with 'merge policy' ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[pulsar-adapters] branch master updated: [pulsar-kafka] add auto update partition support to producer/consumer (#13)

This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git The following commit(s) were added to refs/heads/master by this push: new 0372947 [pulsar-kafka] add auto

[GitHub] [pulsar] dlg99 commented on a change in pull request #10498: SinkContext: ability to seek/pause/resume consumer for a topic

dlg99 commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r632324796 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void close() {

[GitHub] [pulsar] daniel-bartz opened a new issue #10584: broker.conf documentation : wrong tokenSecretKey base64 inline description

daniel-bartz opened a new issue #10584: URL: https://github.com/apache/pulsar/issues/10584 On the website the documentation to pass a token in base64 mention to use `tokenSecretKey=data:;base64,**` However I could not have it working using (without the semicolon)

[GitHub] [pulsar] atezs82 commented on pull request #10574: [Issue 905][api][pulsar-client] add serializable token class

atezs82 commented on pull request #10574: URL: https://github.com/apache/pulsar/pull/10574#issuecomment-841080238 @merlimat thanks for the review, I'll try to modify this accordingly. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [pulsar] eolivelli commented on pull request #10540: Apache Pulsar 2.7.2 blog page

eolivelli commented on pull request #10540: URL: https://github.com/apache/pulsar/pull/10540#issuecomment-841130367 thank you @Anonymitaet let's merge this patch **only after** the official announcement of the release -- This is an automated message from the Apache Git Service.

[GitHub] [pulsar] jerrypeng commented on a change in pull request #10498: SinkContext: ability to seek/pause/resume consumer for a topic

jerrypeng commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r632656974 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void

[GitHub] [pulsar] Joshhw commented on issue #7830: Pulsar Proxy doesn't forward credentials correctly with custom authN/authZ

Joshhw commented on issue #7830: URL: https://github.com/apache/pulsar/issues/7830#issuecomment-841298543 I'm not sure this is an issue anymore as I think the `authenticateOriginalAuthData` seemed to work out. I didn't even realize this was still open. -- This is an automated message

[GitHub] [pulsar] eolivelli opened a new pull request #10591: Upgrade NodeJs in Pulsar Build image (used by WebSite Builder)

eolivelli opened a new pull request #10591: URL: https://github.com/apache/pulsar/pull/10591 The website builder CI job uses Node JS but it fails because now it requires a more recent version of Node. We also have to change the PIP 2.7 download script -- This is an automated

[GitHub] [pulsar] eolivelli commented on pull request #10591: Upgrade NodeJs in Pulsar Build image (used by WebSite Builder)

eolivelli commented on pull request #10591: URL: https://github.com/apache/pulsar/pull/10591#issuecomment-841268851 After building this image we have to push it do dockerhub. I do not have the privileges @merlimat -- This is an automated message from the Apache Git Service. To

[GitHub] [pulsar] linlinnn commented on pull request #10590: [CI] Run pulsar-broker tests that don't belong to any TestNG group

linlinnn commented on pull request #10590: URL: https://github.com/apache/pulsar/pull/10590#issuecomment-841276983 There is a flaky test reported in CI. ``` Error: shouldTerminateWhenFutureIsCancelled(org.apache.pulsar.broker.service.GracefulExecutorServicesShutdownTest) Time

  1   2   >