[GitHub] codelipenghui commented on issue #3155: Deferred messages for consumers

codelipenghui commented on issue #3155: Deferred messages for consumers URL: https://github.com/apache/pulsar/pull/3155#issuecomment-446861449 @lovelle You can view the discussion about [PIP-26](https://github.com/apache/pulsar/wiki/PIP-26%3A-Delayed-Message-Delivery) on the

[GitHub] cbornet commented on issue #3104: [Feature request] Namespace/topic rack affinity

cbornet commented on issue #3104: [Feature request] Namespace/topic rack affinity URL: https://github.com/apache/pulsar/issues/3104#issuecomment-446859696 Namespace isolation works fine. What's missing is a little more doc on how to use it. Do you want to close the issue or keep it open

[GitHub] merlimat closed pull request #3174: FIX: EKS load balancer selector should be proxy

merlimat closed pull request #3174: FIX: EKS load balancer selector should be proxy URL: https://github.com/apache/pulsar/pull/3174 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a

[pulsar] branch master updated: FIX: EKS load balancer selector should be proxy (#3174)

This is an automated email from the ASF dual-hosted git repository. mmerli pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/master by this push: new e0792d6 FIX: EKS load balancer selector should

[GitHub] jiazhai commented on issue #3164: Always return the backlog quota for a namespace in rest response

jiazhai commented on issue #3164: Always return the backlog quota for a namespace in rest response URL: https://github.com/apache/pulsar/pull/3164#issuecomment-446841953 rerun cpp tests This is an automated message from the

[GitHub] jiazhai commented on issue #3164: Always return the backlog quota for a namespace in rest response

jiazhai commented on issue #3164: Always return the backlog quota for a namespace in rest response URL: https://github.com/apache/pulsar/pull/3164#issuecomment-446841937 rerun integration tests This is an automated message

[GitHub] jiazhai edited a comment on issue #3160: Fix Spellings

jiazhai edited a comment on issue #3160: Fix Spellings URL: https://github.com/apache/pulsar/pull/3160#issuecomment-446841804 run java8 tests for org.apache.pulsar.admin.cli.TestCmdSources.testCmdSourceConfigFileMissingJar

[GitHub] jiazhai commented on issue #3160: Fix Spellings

jiazhai commented on issue #3160: Fix Spellings URL: https://github.com/apache/pulsar/pull/3160#issuecomment-446841804 run java8 tests This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] jiazhai closed issue #3119: [Feature request] Make brokers read on closest Bookie

jiazhai closed issue #3119: [Feature request] Make brokers read on closest Bookie URL: https://github.com/apache/pulsar/issues/3119 This is an automated message from the Apache Git Service. To respond to the message, please

[pulsar] branch master updated: Add bookkeeperClientRegionawarePolicyEnabled and bookkeeperClientReor… (#3171)

This is an automated email from the ASF dual-hosted git repository. zhaijia 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 24cc4bb Add

[GitHub] jiazhai closed pull request #3171: Add bookkeeperClientRegionawarePolicyEnabled and bookkeeperClientReor…

jiazhai closed pull request #3171: Add bookkeeperClientRegionawarePolicyEnabled and bookkeeperClientReor… URL: https://github.com/apache/pulsar/pull/3171 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[GitHub] jiazhai commented on issue #3179: [Pulsar-IO] Add Netty Tcp Source Support

jiazhai commented on issue #3179: [Pulsar-IO] Add Netty Tcp Source Support URL: https://github.com/apache/pulsar/pull/3179#issuecomment-446839603 @erenavsarogullari Thanks for the great work. overall lgtm. It would be good to provide some

[pulsar] branch master updated: Cleanup Pulsar IO depdencies (#3182)

This is an automated email from the ASF dual-hosted git repository. zhaijia 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 bd8eb97 Cleanup Pulsar IO depdencies (#3182)

[GitHub] jiazhai closed pull request #3182: Cleanup Pulsar IO dependencies

jiazhai closed pull request #3182: Cleanup Pulsar IO dependencies URL: https://github.com/apache/pulsar/pull/3182 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request

[GitHub] alapha23 closed issue #3094: Error go get pulsar: Unknown type `pulsar_string_list_t` and `pulsarGetTopicPartitionsCallbackProxy`

alapha23 closed issue #3094: Error go get pulsar: Unknown type `pulsar_string_list_t` and `pulsarGetTopicPartitionsCallbackProxy` URL: https://github.com/apache/pulsar/issues/3094 This is an automated message from the

[GitHub] alapha23 commented on issue #3094: Error go get pulsar: Unknown type `pulsar_string_list_t` and `pulsarGetTopicPartitionsCallbackProxy`

alapha23 commented on issue #3094: Error go get pulsar: Unknown type `pulsar_string_list_t` and `pulsarGetTopicPartitionsCallbackProxy` URL: https://github.com/apache/pulsar/issues/3094#issuecomment-446838207 Thank you for the reply. I fixed the issue by checkout to the correct

[GitHub] aahmed-se commented on issue #3181: Fix Spellings and Code Cleanup

aahmed-se commented on issue #3181: Fix Spellings and Code Cleanup URL: https://github.com/apache/pulsar/pull/3181#issuecomment-446837979 rerun java8 tests This is an automated message from the Apache Git Service. To

[GitHub] aahmed-se commented on issue #3181: Fix Spellings and Code Cleanup

aahmed-se commented on issue #3181: Fix Spellings and Code Cleanup URL: https://github.com/apache/pulsar/pull/3181#issuecomment-446834713 rerun integration tests This is an automated message from the Apache Git Service. To

[GitHub] aahmed-se commented on issue #3181: Fix Spellings and Code Cleanup

aahmed-se commented on issue #3181: Fix Spellings and Code Cleanup URL: https://github.com/apache/pulsar/pull/3181#issuecomment-446834599 run integration tests This is an automated message from the Apache Git Service. To

[GitHub] aahmed-se commented on issue #3181: Fix Spellings and Code Cleanup

aahmed-se commented on issue #3181: Fix Spellings and Code Cleanup URL: https://github.com/apache/pulsar/pull/3181#issuecomment-446830121 run cpp tests This is an automated message from the Apache Git Service. To respond to

[GitHub] jerrypeng closed pull request #3175: cleaning up pom for pulsar-client-schema

jerrypeng closed pull request #3175: cleaning up pom for pulsar-client-schema URL: https://github.com/apache/pulsar/pull/3175 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign

[pulsar] branch master updated: cleaning up pom for pulsar-client-schema (#3175)

This is an automated email from the ASF dual-hosted git repository. jerrypeng 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 c44294d cleaning up pom for

[GitHub] lovelle edited a comment on issue #3155: Deferred messages for consumers

lovelle edited a comment on issue #3155: Deferred messages for consumers URL: https://github.com/apache/pulsar/pull/3155#issuecomment-446819094 @codelipenghui > If can't depends on client clock, i think publish time now be client-generated Yes, as far as I understand publish

[GitHub] lovelle commented on issue #3155: Deferred messages for consumers

lovelle commented on issue #3155: Deferred messages for consumers URL: https://github.com/apache/pulsar/pull/3155#issuecomment-446819094 > If can't depends on client clock, i think publish time now be client-generated Yes, as far as I understand publish time is set

[GitHub] srkukarni commented on a change in pull request #3181: Fix Spellings and Code Cleanup

srkukarni commented on a change in pull request #3181: Fix Spellings and Code Cleanup URL: https://github.com/apache/pulsar/pull/3181#discussion_r241249051 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java

[pulsar] branch master updated: Check if log folder exists (#3165)

This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/master by this push: new 1c8305d Check if log folder exists (#3165)

[GitHub] srkukarni closed pull request #3165: Check if log folder exists

srkukarni closed pull request #3165: Check if log folder exists URL: https://github.com/apache/pulsar/pull/3165 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request

[GitHub] srkukarni commented on a change in pull request #3181: Fix Spellings and Code Cleanup

srkukarni commented on a change in pull request #3181: Fix Spellings and Code Cleanup URL: https://github.com/apache/pulsar/pull/3181#discussion_r241245530 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java

[GitHub] srkukarni commented on a change in pull request #3181: Fix Spellings and Code Cleanup

srkukarni commented on a change in pull request #3181: Fix Spellings and Code Cleanup URL: https://github.com/apache/pulsar/pull/3181#discussion_r241245146 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java

[GitHub] srkukarni opened a new pull request #3182: Cleanup Pulsar IO dependencies

srkukarni opened a new pull request #3182: Cleanup Pulsar IO dependencies URL: https://github.com/apache/pulsar/pull/3182 ### Motivation Pulsar IO Core does not have any dependencies on logging or protobuf stuff. ### Modifications Describe the modifications you've done.

[GitHub] srkukarni closed pull request #3166: Sources/Sinks can be launched using fat jars as well

srkukarni closed pull request #3166: Sources/Sinks can be launched using fat jars as well URL: https://github.com/apache/pulsar/pull/3166 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this

[GitHub] aahmed-se opened a new pull request #3181: Fix Spellings and Code Cleanup

aahmed-se opened a new pull request #3181: Fix Spellings and Code Cleanup URL: https://github.com/apache/pulsar/pull/3181 Resolve minor spelling issue and formatting. This is an automated message from the Apache Git Service.

[pulsar] branch master updated: Cleaning up io deps (#3176)

This is an automated email from the ASF dual-hosted git repository. jerrypeng 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 9cdb7fc Cleaning up io deps (#3176) 9cdb7fc

[GitHub] jerrypeng closed pull request #3176: Cleaning up io deps

jerrypeng closed pull request #3176: Cleaning up io deps URL: https://github.com/apache/pulsar/pull/3176 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request (from a

[GitHub] merlimat commented on issue #3174: FIX: EKS load balancer selector should be proxy

merlimat commented on issue #3174: FIX: EKS load balancer selector should be proxy URL: https://github.com/apache/pulsar/pull/3174#issuecomment-446793487 run integration tests This is an automated message from the Apache Git

[GitHub] srkukarni commented on a change in pull request #3166: Sources/Sinks can be launched using fat jars as well

srkukarni commented on a change in pull request #3166: Sources/Sinks can be launched using fat jars as well URL: https://github.com/apache/pulsar/pull/3166#discussion_r241219372 ## File path:

[GitHub] erenavsarogullari commented on issue #3179: [Pulsar-IO] Add Netty Tcp Source Support

erenavsarogullari commented on issue #3179: [Pulsar-IO] Add Netty Tcp Source Support URL: https://github.com/apache/pulsar/pull/3179#issuecomment-446777460 Thanks @jerrypeng. Will be addressing them ;) This is an automated

[GitHub] jerrypeng commented on a change in pull request #3166: Sources/Sinks can be launched using fat jars as well

jerrypeng commented on a change in pull request #3166: Sources/Sinks can be launched using fat jars as well URL: https://github.com/apache/pulsar/pull/3166#discussion_r241217111 ## File path:

[GitHub] jerrypeng commented on issue #3179: [Pulsar-IO] Add Netty Tcp Source Support

jerrypeng commented on issue #3179: [Pulsar-IO] Add Netty Tcp Source Support URL: https://github.com/apache/pulsar/pull/3179#issuecomment-446775169 PR looks good just some minor comments This is an automated message from the

[GitHub] jerrypeng commented on a change in pull request #3179: [Pulsar-IO] Add Netty Tcp Source Support

jerrypeng commented on a change in pull request #3179: [Pulsar-IO] Add Netty Tcp Source Support URL: https://github.com/apache/pulsar/pull/3179#discussion_r241214656 ## File path: pulsar-io/netty/src/main/resources/META-INF/services/pulsar-io.yaml ## @@ -0,0 +1,22 @@ +#

[GitHub] tobgu opened a new issue #3180: Go client Reader panics when passing custom StartMessageID

tobgu opened a new issue #3180: Go client Reader panics when passing custom StartMessageID URL: https://github.com/apache/pulsar/issues/3180 Expected behavior I can pass arbitrary type implementing the `pulsar.MessageID` interface in `pulsar.ReaderOptions`when creating a

[GitHub] erenavsarogullari opened a new pull request #3179: [Pulsar-IO] Add Netty Tcp Source Support

erenavsarogullari opened a new pull request #3179: [Pulsar-IO] Add Netty Tcp Source Support URL: https://github.com/apache/pulsar/pull/3179 ### Motivation Netty is NIO client server framework by supporting asynchronous event-driven communication and custom protocol implementation.

[GitHub] ivankelly opened a new issue #3178: Broker should not serve requests until it is ready

ivankelly opened a new issue #3178: Broker should not serve requests until it is ready URL: https://github.com/apache/pulsar/issues/3178 See discussion on #2942 . The broker opens port 6650 before it is actually fully initialized, which can cause clients to see weird things (broker

[GitHub] ivankelly closed issue #2942: Intermittent test failure in TestS3Offload

ivankelly closed issue #2942: Intermittent test failure in TestS3Offload URL: https://github.com/apache/pulsar/issues/2942 This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] ivankelly commented on issue #2942: Intermittent test failure in TestS3Offload

ivankelly commented on issue #2942: Intermittent test failure in TestS3Offload URL: https://github.com/apache/pulsar/issues/2942#issuecomment-446759535 Ok, lets create an issue for this at least. I'll close this one. This is

[GitHub] ivankelly commented on issue #3162: There should be a way to get the last message ID of a topic

ivankelly commented on issue #3162: There should be a way to get the last message ID of a topic URL: https://github.com/apache/pulsar/issues/3162#issuecomment-446759080 There was a conversation about whether to expose it when implementing Reader#hasMessageAvailable().

[GitHub] aahmed-se commented on issue #3160: Fix Spellings

aahmed-se commented on issue #3160: Fix Spellings URL: https://github.com/apache/pulsar/pull/3160#issuecomment-446756386 run java8 tests This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] jerrypeng closed pull request #3170: Fix: Use regular ThreadLocal instead of the netty one in Schema

jerrypeng closed pull request #3170: Fix: Use regular ThreadLocal instead of the netty one in Schema URL: https://github.com/apache/pulsar/pull/3170 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance:

[GitHub] tobgu opened a new issue #3177: MessageID always seems to serialize to empty slice in Go client Reader

tobgu opened a new issue #3177: MessageID always seems to serialize to empty slice in Go client Reader URL: https://github.com/apache/pulsar/issues/3177 Expected behavior ```go // Error checks left for brevity, these are checked in real code reader, _ :=

[GitHub] jerrypeng opened a new pull request #3176: Cleaning up io deps

jerrypeng opened a new pull request #3176: Cleaning up io deps URL: https://github.com/apache/pulsar/pull/3176 ### Motivation We unnecessarily include pulsar-io-core in many places This is an automated message from

[GitHub] aahmed-se commented on issue #3165: Check if log folder exists

aahmed-se commented on issue #3165: Check if log folder exists URL: https://github.com/apache/pulsar/pull/3165#issuecomment-446740305 run java8 tests This is an automated message from the Apache Git Service. To respond to the

[GitHub] jerrypeng opened a new pull request #3175: cleaning up pom for pulsar-client-schema

jerrypeng opened a new pull request #3175: cleaning up pom for pulsar-client-schema URL: https://github.com/apache/pulsar/pull/3175 ### Motivation The pom for pulsar-client-schema module has many unnecessary items. Cleaning up the unnecessary items to reduce complexity and chances

[GitHub] aahmed-se commented on issue #3165: Check if log folder exists

aahmed-se commented on issue #3165: Check if log folder exists URL: https://github.com/apache/pulsar/pull/3165#issuecomment-446733230 run integration tests This is an automated message from the Apache Git Service. To respond

[GitHub] aahmed-se commented on issue #3160: Fix Spellings

aahmed-se commented on issue #3160: Fix Spellings URL: https://github.com/apache/pulsar/pull/3160#issuecomment-446733220 run integration tests This is an automated message from the Apache Git Service. To respond to the

[GitHub] jerrypeng commented on issue #3170: Fix: Use regular ThreadLocal instead of the netty one in Schema

jerrypeng commented on issue #3170: Fix: Use regular ThreadLocal instead of the netty one in Schema URL: https://github.com/apache/pulsar/pull/3170#issuecomment-446722309 rerun java8 tests This is an automated message from

[pulsar] branch merlimat-patch-1 deleted (was 49f22e2)

This is an automated email from the ASF dual-hosted git repository. mmerli pushed a change to branch merlimat-patch-1 in repository https://gitbox.apache.org/repos/asf/pulsar.git. was 49f22e2 Update pulsar.properties The revisions that were on this branch are still contained in other

[pulsar] branch jf2.2-staging deleted (was 8a93afd)

This is an automated email from the ASF dual-hosted git repository. mmerli pushed a change to branch jf2.2-staging in repository https://gitbox.apache.org/repos/asf/pulsar.git. was 8a93afd Update release-notes.md The revisions that were on this branch are still contained in other

[GitHub] sinzin91 opened a new pull request #3174: FIX: EKS load balancer selector should be proxy

sinzin91 opened a new pull request #3174: FIX: EKS load balancer selector should be proxy URL: https://github.com/apache/pulsar/pull/3174 ### Motivation If the selector is broker, the client will try to connect to the internal broker IP, which won't work. The selector should be

[GitHub] shalinseban commented on issue #3173: Pulsar Functions ( Python) : Support to submit python modules

shalinseban commented on issue #3173: Pulsar Functions ( Python) : Support to submit python modules URL: https://github.com/apache/pulsar/issues/3173#issuecomment-446718453 Got it. Thanks for clarifying that. This is an

[GitHub] srkukarni commented on issue #3173: Pulsar Functions ( Python) : Support to submit python modules

srkukarni commented on issue #3173: Pulsar Functions ( Python) : Support to submit python modules URL: https://github.com/apache/pulsar/issues/3173#issuecomment-446715363 Unfortunately we are a little behind wrt documentation. You can create a wheel file and just submit it using the same

[GitHub] shalinseban edited a comment on issue #3173: Pulsar Functions ( Python) : Support to submit python modules

shalinseban edited a comment on issue #3173: Pulsar Functions ( Python) : Support to submit python modules URL: https://github.com/apache/pulsar/issues/3173#issuecomment-446714928 Interesting. Is the documentation updated around submitting `.whl` as pulsar functions. I can't seem to find

[GitHub] shalinseban commented on issue #3173: Pulsar Functions ( Python) : Support to submit python modules

shalinseban commented on issue #3173: Pulsar Functions ( Python) : Support to submit python modules URL: https://github.com/apache/pulsar/issues/3173#issuecomment-446714928 Interesting. Is there documentation updated around submitting `.whl` as pulsar functions. I can't seem to find it.

[GitHub] srkukarni commented on issue #3173: Pulsar Functions ( Python) : Support to submit python modules

srkukarni commented on issue #3173: Pulsar Functions ( Python) : Support to submit python modules URL: https://github.com/apache/pulsar/issues/3173#issuecomment-446710834 This is actually for 2.2 release. This is an

[GitHub] merlimat commented on a change in pull request #3167: add eks broker proxy

merlimat commented on a change in pull request #3167: add eks broker proxy URL: https://github.com/apache/pulsar/pull/3167#discussion_r241150293 ## File path: deployment/kubernetes/aws/proxy.yaml ## @@ -0,0 +1,85 @@ +# +# Licensed to the Apache Software Foundation (ASF)

[GitHub] merlimat closed pull request #3172: Modify producer handler of WebSocket to send ack to client asynchronously

merlimat closed pull request #3172: Modify producer handler of WebSocket to send ack to client asynchronously URL: https://github.com/apache/pulsar/pull/3172 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[pulsar] branch master updated: Modify producer handler of WebSocket to send ack to client asynchronously (#3172)

This is an automated email from the ASF dual-hosted git repository. mmerli pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/master by this push: new 7bda5b6 Modify producer handler of WebSocket

[GitHub] merlimat commented on issue #3170: Fix: Use regular ThreadLocal instead of the netty one in Schema

merlimat commented on issue #3170: Fix: Use regular ThreadLocal instead of the netty one in Schema URL: https://github.com/apache/pulsar/pull/3170#issuecomment-446698194 run java8 tests This is an automated message from the

[GitHub] merlimat closed pull request #3167: add eks broker proxy

merlimat closed pull request #3167: add eks broker proxy URL: https://github.com/apache/pulsar/pull/3167 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request (from a

[pulsar] branch master updated: add eks broker proxy (#3167)

This is an automated email from the ASF dual-hosted git repository. mmerli pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/master by this push: new 04df219 add eks broker proxy (#3167) 04df219

[GitHub] merlimat closed pull request #3169: Issue #2407: make conf file sync with code

merlimat closed pull request #3169: Issue #2407: make conf file sync with code URL: https://github.com/apache/pulsar/pull/3169 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign

[pulsar] branch master updated: make conf file sync with code (#3169)

This is an automated email from the ASF dual-hosted git repository. mmerli pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/master by this push: new 0bfbfb2 make conf file sync with code (#3169)

[GitHub] shalinseban commented on issue #3173: Pulsar Functions ( Python) : Support to submit python modules

shalinseban commented on issue #3173: Pulsar Functions ( Python) : Support to submit python modules URL: https://github.com/apache/pulsar/issues/3173#issuecomment-446665890 I'm assuming that is for **2.3** release though.

[GitHub] shalinseban closed issue #3173: Pulsar Functions ( Python) : Support to submit python modules

shalinseban closed issue #3173: Pulsar Functions ( Python) : Support to submit python modules URL: https://github.com/apache/pulsar/issues/3173 This is an automated message from the Apache Git Service. To respond to the

[GitHub] shalinseban commented on issue #3173: Pulsar Functions ( Python) : Support to submit python modules

shalinseban commented on issue #3173: Pulsar Functions ( Python) : Support to submit python modules URL: https://github.com/apache/pulsar/issues/3173#issuecomment-446665343 Awesome. Yes it does. This is an automated message

[GitHub] srkukarni commented on issue #3173: Pulsar Functions ( Python) : Support to submit python modules

srkukarni commented on issue #3173: Pulsar Functions ( Python) : Support to submit python modules URL: https://github.com/apache/pulsar/issues/3173#issuecomment-446663357 We already support submitting .whl files. Does that satisfy this requirement?

[GitHub] sijie commented on issue #3161: Message ID of sent message should be returned in Go client producer

sijie commented on issue #3161: Message ID of sent message should be returned in Go client producer URL: https://github.com/apache/pulsar/issues/3161#issuecomment-446618663 /cc @legendtkl This is an automated message from

[GitHub] sijie commented on issue #3162: There should be a way to get the last message ID of a topic

sijie commented on issue #3162: There should be a way to get the last message ID of a topic URL: https://github.com/apache/pulsar/issues/3162#issuecomment-446616456 GetLastMessageId request is already there. However it is not exposed. It should be very straightforward to expose it.

[GitHub] sijie commented on issue #3119: [Feature request] Make brokers read on closest Bookie

sijie commented on issue #3119: [Feature request] Make brokers read on closest Bookie URL: https://github.com/apache/pulsar/issues/3119#issuecomment-446614684 > What should be the default value for these options ? Enabled/disabled ? better to be "disabled" > Should the

[GitHub] shalinseban opened a new issue #3173: Pulsar Functions ( Python) : Support to submit python modules

shalinseban opened a new issue #3173: Pulsar Functions ( Python) : Support to submit python modules URL: https://github.com/apache/pulsar/issues/3173 Expected behavior We should be able to submit a pulsar function as a python module rather than a python file, i.e, ability to

[GitHub] massakam opened a new pull request #3172: Modify producer handler of WebSocket to send ack to client asynchrono…

massakam opened a new pull request #3172: Modify producer handler of WebSocket to send ack to client asynchrono… URL: https://github.com/apache/pulsar/pull/3172 …usly ### Motivation Recently, the WebSocket proxy in our Pulsar cluster hangs occasionally. A lot of connections

[GitHub] cbornet opened a new pull request #3171: Add bookkeeperClientRegionawarePolicyEnabled and bookkeeperClientReor…

cbornet opened a new pull request #3171: Add bookkeeperClientRegionawarePolicyEnabled and bookkeeperClientReor… URL: https://github.com/apache/pulsar/pull/3171 …derReadSequenceEnabled config parameters Fix #3119 ### Motivation This allows to configure region-aware

[GitHub] ivankelly commented on issue #2865: Refactored JCloud Tiered Storage

ivankelly commented on issue #2865: Refactored JCloud Tiered Storage URL: https://github.com/apache/pulsar/pull/2865#issuecomment-446529648 Also, the old config values will still have to work. So you'll need some compatibility translation layer.

[GitHub] ivankelly commented on issue #2865: Refactored JCloud Tiered Storage

ivankelly commented on issue #2865: Refactored JCloud Tiered Storage URL: https://github.com/apache/pulsar/pull/2865#issuecomment-446529215 I expect there will be non-jclouds offloaders too. For example, HDFS. [1] might be helpful as an example of doing weird stuff with the config.

[GitHub] cbornet commented on issue #3119: [Feature request] Make brokers read on closest Bookie

cbornet commented on issue #3119: [Feature request] Make brokers read on closest Bookie URL: https://github.com/apache/pulsar/issues/3119#issuecomment-446523322 What should be the default value for these options ? Enabled/disabled ? Should the default policy be rack-aware (current

[GitHub] tobgu commented on issue #2682: The websocket reader API is not including the specified starting message.

tobgu commented on issue #2682: The websocket reader API is not including the specified starting message. URL: https://github.com/apache/pulsar/issues/2682#issuecomment-446509138 Having an option like this on a Reader would be enough for me to close #2682.