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 [maili
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 fo
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 for
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
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 A
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 fr
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
org.apache.pulsar.admin.cli.TestCmdSources.testMissingAr
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, please
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
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 bookkeeperClientRegionawarePolicyE
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 provena
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
[documentation](http://pulsar.apache.org/docs/en/
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)
b
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 (
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 Apach
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 branch.
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 r
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 res
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 respo
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 th
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 pu
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 pulsar-client-sc
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
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
[here](https://gi
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
##
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)
1
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 (fr
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
##
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
##
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.
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 4f2feb0 Sources/Sinks can be launched using
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 is
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.
T
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
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 fo
aahmed-se commented on issue #3165: Check if log folder exists
URL: https://github.com/apache/pulsar/pull/3165#issuecomment-446795689
run java8 tests
This is an automated message from the Apache Git Service.
To respond to the
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
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:
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/LocalRunner.jav
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 me
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:
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/LocalRunner.jav
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 A
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_r241215380
##
File path: pulsar-io/netty/src/test/resources/nettyTcpSourceConfig.yaml
##
@@ -0,0 +1,24 @@
+#
+# Licens
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 @@
+#
+#
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_r241213442
##
File path:
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/NettyTcpSource.java
##
@@ -0,0 +1,7
jerrypeng commented on issue #3176: Cleaning up io deps
URL: https://github.com/apache/pulsar/pull/3176#issuecomment-446772245
rerun java8 tests
This is an automated message from the Apache Git Service.
To respond to the messa
jerrypeng commented on issue #3175: cleaning up pom for pulsar-client-schema
URL: https://github.com/apache/pulsar/pull/3175#issuecomment-446772028
rerun java8 tests
This is an automated message from the Apache Git Service.
To
aahmed-se commented on issue #3165: Check if log folder exists
URL: https://github.com/apache/pulsar/pull/3165#issuecomment-446771042
run java8 tests
This is an automated message from the Apache Git Service.
To respond to the
srkukarni commented on issue #3166: Sources/Sinks can be launched using fat
jars as well
URL: https://github.com/apache/pulsar/pull/3166#issuecomment-446769164
run cpp tests
This is an automated message from the Apache Git Se
merlimat 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-446764706
@alapha23 Sorry missed this issue before.
The problem is that `go get` fet
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 Reade
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.
Re
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
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 Git
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 a
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().
merlimat commented on issue #2942: Intermittent test failure in TestS3Offload
URL: https://github.com/apache/pulsar/issues/2942#issuecomment-446758926
> doesn't actually do anything to prevent the broker from serving traffic
before it's ready, it just doesn't advertize it.
That is
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, plea
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 e10e096 Use regular ThreadLocal instead of t
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:
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, _ := client.CreateReade
aahmed-se commented on issue #3160: Fix Spellings
URL: https://github.com/apache/pulsar/pull/3160#issuecomment-446741052
run java8 tests
This is an automated message from the Apache Git Service.
To respond to the message, plea
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
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
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
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 t
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 message
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 th
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 refe
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 referenc
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 pro
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 auto
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 -
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 i
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. Th
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 automated
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) und
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 pr
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 to
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 A
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 fo
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 is
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 p
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)
0
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.
Th
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 mess
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 f
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?
-
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 th
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. @jiazha
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 default
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 pa
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 i
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 polic
jerrypeng opened a new pull request #3170: Use regular ThreadLocal instead of
the netty one in Schema
URL: https://github.com/apache/pulsar/pull/3170
### Motivation
Since pulsar-client-schema does not depend on netty, we can't use
FastThreadLocal from netty or it will cause dependen
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.
ivankelly edited a comment 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.
https://github.com/apache/pulsar/commit/052c3b0dc418d1ec29c3d221023
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.
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 defaul
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.
-
99 matches
Mail list logo