stanbog opened a new issue #10434:
URL: https://github.com/apache/pulsar/issues/10434
Hello,
We have a pulsar-broker cluster made from 3 nodes.
We would like to forwards the logs into splunk so we are reading the file`
/opt/pulsar/logs/pulsar-broker.log`.
However, the pulsar-br
codelipenghui commented on a change in pull request #10319:
URL: https://github.com/apache/pulsar/pull/10319#discussion_r622786325
##
File path:
pulsar-common/src/main/java/org/apache/pulsar/common/naming/TopicName.java
##
@@ -331,11 +331,21 @@ public String getPersistenceNami
codelipenghui merged pull request #10422:
URL: https://github.com/apache/pulsar/pull/10422
--
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,
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 5238822 [Transaction] Fix transaction buffer handler sync problem.
(#10424)
add bdb0990 [Transaction] Transa
RobertIndie commented on a change in pull request #10420:
URL: https://github.com/apache/pulsar/pull/10420#discussion_r622801176
##
File path:
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSink.java
##
@@ -121,10 +130,8 @@ public void write(Record record)
lhotari opened a new pull request #10435:
URL: https://github.com/apache/pulsar/pull/10435
- backports #10413 to branch-2.7
--
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.
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.7 by this push:
new 90c0c18 [Broker] Fix issue in reusin
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.7 by this push:
new 3be19ec fix standalone image error (
eolivelli commented on pull request #10337:
URL: https://github.com/apache/pulsar/pull/10337#issuecomment-829019260
@315157973
this patch does not apply to branch-2.7
can you please create a new PR for branch-2.7 ?
--
This is an automated message from the Apache Git Service.
To res
codelipenghui commented on issue #10433:
URL: https://github.com/apache/pulsar/issues/10433#issuecomment-829019325
@lhotari The pool here we are using is a thread-local pool, and always use
the the same thread for a managed ledger to insert entry to the cache
https://github.com/apache/puls
eolivelli commented on pull request #10317:
URL: https://github.com/apache/pulsar/pull/10317#issuecomment-829019934
I am removing 2.7.2 label,
does are built from master, correct ?
@Anonymitaet
--
This is an automated message from the Apache Git Service.
To respond to the message,
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.7 by this push:
new 4d9b94c Support advertisedListeners
eolivelli commented on pull request #10307:
URL: https://github.com/apache/pulsar/pull/10307#issuecomment-829021127
This patch cannot be ported to branch-2.7, as it requires CI changes.
CI changed a lot between 2.7 and 2.8
--
This is an automated message from the Apache Git Service.
To
eolivelli commented on pull request #9440:
URL: https://github.com/apache/pulsar/pull/9440#issuecomment-829021833
This patch is too dangerous for 2.7.2 IMHO, I have removed the release/2.7.2
label
@codelipenghui
--
This is an automated message from the Apache Git Service.
To respond
eolivelli commented on pull request #10305:
URL: https://github.com/apache/pulsar/pull/10305#issuecomment-829022689
This patch does not apply to branch-2.7
--
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
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.7 by this push:
new d2138f7 [Cursor] add return statemen
eolivelli commented on pull request #9349:
URL: https://github.com/apache/pulsar/pull/9349#issuecomment-829029259
this patch does not apply to branch-7.2
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above t
eolivelli commented on pull request #10028:
URL: https://github.com/apache/pulsar/pull/10028#issuecomment-829030524
This patch does not apply to branch-7.2
--
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
eolivelli commented on pull request #10098:
URL: https://github.com/apache/pulsar/pull/10098#issuecomment-829031452
LightProto is not present in branch-7.2, removing release/2.7.2 label
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.7 by this push:
new c088717 [ISSUE 10153][Go Function] f
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.7 by this push:
new 16387e2 [WebSocket Client] WebSocket
eolivelli commented on pull request #10220:
URL: https://github.com/apache/pulsar/pull/10220#issuecomment-829032589
I am not sure it is safe to apply this patch to branch-2.7
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.7 by this push:
new 2623241 Suppress printing "skip Proc
lhotari commented on issue #10433:
URL: https://github.com/apache/pulsar/issues/10433#issuecomment-829036198
@codelipenghui The pool is a thread-local pool, but the instance might be
returned to a pool where it wasn't initially created, no?
Thanks for pointing to the OpAddEntry code
lhotari edited a comment on issue #10433:
URL: https://github.com/apache/pulsar/issues/10433#issuecomment-829036198
@codelipenghui Thanks for pointing to the OpAddEntry code location. I
initially didn't realize that the code had both `entry` and `cachedEntry` and
that it's the `entry.data`
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.7 by this push:
new fe7ee88 [Issue 10221] Fix authorizat
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.7 by this push:
new c941860 [Security] Upgrade commons-i
eolivelli commented on pull request #10121:
URL: https://github.com/apache/pulsar/pull/10121#issuecomment-829040007
@315157973 this patch does not apply to branch-7.2.
Do you mind sending a PR against branch-7.2 ?
this way we can deliver this fix in 2.7.2
--
This is an automated mes
lhotari commented on issue #10433:
URL: https://github.com/apache/pulsar/issues/10433#issuecomment-829047679
> The pool here we are using is a thread-local pool, and always use the the
same thread for a managed ledger to insert entry to the cache
@codelipenghui it seems that [Netty's
lhotari opened a new pull request #10436:
URL: https://github.com/apache/pulsar/pull/10436
- backport #10278
--
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 ab
Anonymitaet commented on pull request #10317:
URL: https://github.com/apache/pulsar/pull/10317#issuecomment-829055022
@eolivelli I've added docs for both 2.7.2 and master.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
Anonymitaet edited a comment on pull request #10317:
URL: https://github.com/apache/pulsar/pull/10317#issuecomment-829055022
@eolivelli I've added docs for both 2.7.2 and master, so users can read this
content in 2.7.2 and master.
--
This is an automated message from the Apache Git Servi
codelipenghui commented on pull request #10121:
URL: https://github.com/apache/pulsar/pull/10121#issuecomment-829058345
This PR depends on https://github.com/apache/pulsar/pull/10061, we need to
cherry-pick #10061 first.
--
This is an automated message from the Apache Git Service.
To res
AtticusLv opened a new issue #10437:
URL: https://github.com/apache/pulsar/issues/10437
Please support java and reactor client, reactive programming based client
api.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
lhotari commented on issue #10434:
URL: https://github.com/apache/pulsar/issues/10434#issuecomment-829068558
logging to the log file can be achieved by setting
`PULSAR_ROUTING_APPENDER_DEFAULT=RollingFile` .
The roll-over happens once per day or when the size of the log file reaches
1G
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from c941860 [Security] Upgrade commons-io to address CVE-2021-29425
(#10287)
new 26c2837 Fix schema ledger d
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit af6c2fa5659185193fa4af413aa5cea0007b81cd
Author: lipenghui
AuthorDate: Thu Apr 22 01:04:52 2021 +0800
Add unde
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 26c2837cb9e374942494e7f32f2d4d8f6df480f6
Author: lipenghui
AuthorDate: Tue Apr 27 23:57:34 2021 +0800
Fix sche
vroyer opened a new issue #10438:
URL: https://github.com/apache/pulsar/issues/10438
When the schema is not known at compile time, a `Consumer`
should be able to get the message schema.
Currently, a `Consumer` can get the AVRO message and retreive
its schema, but if the message is a
lhotari commented on pull request #10436:
URL: https://github.com/apache/pulsar/pull/10436#issuecomment-829073111
/pulsarbot run-failure-checks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to th
lhotari commented on issue #10437:
URL: https://github.com/apache/pulsar/issues/10437#issuecomment-829081404
@AtticusLv Thanks for the feature request. I have some plans for this. The
initial support would be an adapter library which adapts the existing Pulsar
Java Client's Async API to Pr
This is an automated email from the ASF dual-hosted git repository.
bogong pushed a change to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from af6c2fa Add underReplicate state in the topic internal stats (#10013)
new bf81fbf [Python] Fix nested Map
This is an automated email from the ASF dual-hosted git repository.
bogong pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit bf81fbf79e3222db01e6105b6330960c52ab42f2
Author: Yunze Xu
AuthorDate: Fri Feb 12 02:10:11 2021 +0800
[Python] F
This is an automated email from the ASF dual-hosted git repository.
bogong pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 9a72fe4fa137e369aa27150e46c41b67041de022
Author: congbo <39078850+congbobo...@users.noreply.github.com>
AuthorDate: M
eolivelli commented on issue #10438:
URL: https://github.com/apache/pulsar/issues/10438#issuecomment-829084318
@congbobo184 here
https://github.com/apache/pulsar/pull/9970/files#diff-955419b4b0ad976e96f9f7595989e79c391109aeaa304bd286a80fc6eb9360c7R324
you are adding MessageImpl#getSchema()
eolivelli commented on a change in pull request #10428:
URL: https://github.com/apache/pulsar/pull/10428#discussion_r622887818
##
File path:
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/AvroSchemaTest.java
##
@@ -423,4 +425,16 @@ public void testAvroSchemaU
eolivelli commented on pull request #10121:
URL: https://github.com/apache/pulsar/pull/10121#issuecomment-829088145
I would like to not cherry pick #10061 it looks to me that it is better not
to introduce now refactor, now that we are close to the release
@codelipenghui
--
This is an
eolivelli commented on pull request #7406:
URL: https://github.com/apache/pulsar/pull/7406#issuecomment-829090882
@merlimat do you want to rebase this onto current master ?
it looks like it is a very good improvement
--
This is an automated message from the Apache Git Service.
To respo
codelipenghui commented on pull request #10420:
URL: https://github.com/apache/pulsar/pull/10420#issuecomment-829091168
@dlg99 @RobertIndie We can leverage the max unack message limitation to
limit the memory of the connector when using `retainOrdering=false`, it needs
users to use the Sha
zymap commented on issue #8989:
URL: https://github.com/apache/pulsar/issues/8989#issuecomment-829110658
Hi @rounak11, which pulsar version you are using?
For the first issue, I can use a superuser to produce and consume messages
with pulsar 2.7.1.
For the second issue, I think y
zymap commented on issue #8989:
URL: https://github.com/apache/pulsar/issues/8989#issuecomment-829120675
@lmccay I think it's a document issue. You can find the rest API here:
https://pulsar.incubator.apache.org/admin-rest-api/#operation/deleteTopic
--
This is an automated message from t
lhotari opened a new issue #10439:
URL: https://github.com/apache/pulsar/issues/10439
**Is your enhancement request related to a problem? Please describe.**
Pulsar doesn't take advantage of Bookkeeper's client-side and server-side
backpressure features.
https://github.com/apache/
eolivelli commented on issue #10439:
URL: https://github.com/apache/pulsar/issues/10439#issuecomment-829134966
@lhotari since 2.8 you can configure the bookkeeper client inside the broker
just by adding
bookkeeper_xxx in broker.conf
check for instance the case of "bookkeeper_oppor
lhotari commented on issue #10439:
URL: https://github.com/apache/pulsar/issues/10439#issuecomment-829147823
@eolivelli Would it be possible to cherry-pick #9232 to branch-2.7 so that
it would be possible to configure `waitTimeoutOnBackpressureMs` on the broker
side by using `bookkeeper_wa
lhotari commented on issue #10136:
URL: https://github.com/apache/pulsar/issues/10136#issuecomment-829153804
Is this a duplicate of #9562 ?
--
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 sp
galrose commented on issue #10136:
URL: https://github.com/apache/pulsar/issues/10136#issuecomment-829159281
No because the maxMessageBufferSizeInMb is just the buffer for messages.
Even after there is no producers and the all the data is in the bookie then the
memory stays the same, inste
lhotari commented on issue #10136:
URL: https://github.com/apache/pulsar/issues/10136#issuecomment-829159713
For direct memory leaks, it's most likely about Netty pooled memory. For
debugging the situation, it might be useful to check if there are log messages
from the Netty leak detector.
galrose commented on issue #10136:
URL: https://github.com/apache/pulsar/issues/10136#issuecomment-829160476
Thanks I'll try to do that :)
--
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 sp
eolivelli commented on issue #10439:
URL: https://github.com/apache/pulsar/issues/10439#issuecomment-829160427
@lhotari yes
I have picked it to branch-7.2
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.7 by this push:
new baddf9d Allow to configure BookKeepe
vroyer commented on a change in pull request #10428:
URL: https://github.com/apache/pulsar/pull/10428#discussion_r622975597
##
File path:
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/AvroSchemaTest.java
##
@@ -423,4 +425,16 @@ public void testAvroSchemaUser
eolivelli merged pull request #10435:
URL: https://github.com/apache/pulsar/pull/10435
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, ple
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.7 by this push:
new 1f467a0 [Broker] Make
Persistent*Di
eolivelli merged pull request #10436:
URL: https://github.com/apache/pulsar/pull/10436
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, ple
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.7 by this push:
new b68606a [Java Client] Fix concurrenc
lhotari edited a comment on issue #10136:
URL: https://github.com/apache/pulsar/issues/10136#issuecomment-829159713
For direct memory leaks, it's most likely about Netty pooled memory. For
debugging the situation, it might be useful to check if there are log messages
from the Netty leak de
lhotari edited a comment on issue #10136:
URL: https://github.com/apache/pulsar/issues/10136#issuecomment-829159713
For direct memory leaks, it's most likely about Netty pooled memory. For
debugging the situation, it might be useful to check if there are log messages
from the Netty leak de
lhotari edited a comment on issue #10136:
URL: https://github.com/apache/pulsar/issues/10136#issuecomment-829159713
For direct memory leaks, it's most likely about Netty pooled memory. For
debugging the situation, it might be useful to check if there are log messages
from the Netty leak de
BewareMyPower commented on pull request #10220:
URL: https://github.com/apache/pulsar/pull/10220#issuecomment-829175188
@eolivelli I think it's safe to cherry-pick to branch-2.7
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
lhotari commented on issue #10136:
URL: https://github.com/apache/pulsar/issues/10136#issuecomment-829183581
For example, In the k8s Helm chart deployment, an environment variable can
be set for the broker by adding it under `broker.configData` in the
`values.yaml` for the deployment.
lhotari edited a comment on issue #10136:
URL: https://github.com/apache/pulsar/issues/10136#issuecomment-829183581
For example, In the k8s Helm chart deployment, an environment variable can
be set for the broker by adding it under `broker.configData` in the
`values.yaml` for the deploymen
MarvinCai commented on pull request #10401:
URL: https://github.com/apache/pulsar/pull/10401#issuecomment-829200600
/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
eolivelli commented on pull request #10220:
URL: https://github.com/apache/pulsar/pull/10220#issuecomment-829207327
It does not apply cleanly to branch-2.7
--
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
josephlim75 commented on issue #572:
URL: https://github.com/apache/pulsar/issues/572#issuecomment-829216496
I hope Pulsar and BookKeeper will ditch Zookeeper and come out with their
internal built-in cluster coordination like Raft, what new Kafka 2.8 has
developed `KIP-500` and also how D
BewareMyPower commented on pull request #10220:
URL: https://github.com/apache/pulsar/pull/10220#issuecomment-829220049
OK, I didn't notice it just now.
--
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
josephlim75 edited a comment on issue #572:
URL: https://github.com/apache/pulsar/issues/572#issuecomment-829216496
I hope Pulsar and BookKeeper will ditch Zookeeper and come out with their
internal built-in cluster coordination like Raft, what new Kafka 2.8 has
developed `KIP-500` and als
RobertIndie commented on pull request #10420:
URL: https://github.com/apache/pulsar/pull/10420#issuecomment-829228354
Here I did some stress tests:
* Start the sink connector with `retainOrdering` enabled.
![image](https://user-images.githubusercontent.com/16974619/116555693-40c2d700-
codelipenghui commented on pull request #10420:
URL: https://github.com/apache/pulsar/pull/10420#issuecomment-829233360
@dlg99 Please help take a look.
--
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
eolivelli commented on issue #10438:
URL: https://github.com/apache/pulsar/issues/10438#issuecomment-829234676
--
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 a
merlimat commented on pull request #7406:
URL: https://github.com/apache/pulsar/pull/7406#issuecomment-829235143
Yes, I’ll get this ready in the next few days. There are also some
improvements I want to do to this PR.
--
This is an automated message from the Apache Git Service.
To respo
abhilashmandaliya opened a new issue #10440:
URL: https://github.com/apache/pulsar/issues/10440
**Describe the bug**
Pulsar IO Sink config parsing is using Gson to parse the user-supplied
config. Gson parses numeric values to double if we parse it to Java's Object
class. This can be a p
abhilashmandaliya commented on pull request #10214:
URL: https://github.com/apache/pulsar/pull/10214#issuecomment-829261022
Closing due to some branching issue.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
abhilashmandaliya closed pull request #10214:
URL: https://github.com/apache/pulsar/pull/10214
--
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 serv
abhilashmandaliya opened a new pull request #10441:
URL: https://github.com/apache/pulsar/pull/10441
Fixes #10440
### Motivation
Data types should be preserved after deserializing the sink/source config.
### Modifications
Using ObjectMapper instead of Gson to pars
abhilashmandaliya commented on a change in pull request #10441:
URL: https://github.com/apache/pulsar/pull/10441#discussion_r623086334
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
##
@@ -764,8 +763,18 @@ public void shutdown() t
abhilashmandaliya commented on pull request #10441:
URL: https://github.com/apache/pulsar/pull/10441#issuecomment-829270164
@MarvinCai @eolivelli @315157973 @lhotari kindly review it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
dinghram commented on issue #10433:
URL: https://github.com/apache/pulsar/issues/10433#issuecomment-829275756
Pulsar version: 2.7.0 + cherry-picked fixes
Deployment: helm
Java version:
openjdk version "1.8.0_282"
OpenJDK Runtime Environment (IcedTea 3.18.0) (build 1.8.0_282-
galrose commented on pull request #7406:
URL: https://github.com/apache/pulsar/pull/7406#issuecomment-829277505
@merlimat thats great thank you
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to th
lhotari opened a new pull request #10442:
URL: https://github.com/apache/pulsar/pull/10442
### Motivation & Modifications
Adds instructions for building custom docker images to README.md
--
This is an automated message from the Apache Git Service.
To respond to the message, please
lhotari commented on pull request #10442:
URL: https://github.com/apache/pulsar/pull/10442#issuecomment-829280896
@Anonymitaet @Huanli-Meng Please review
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above t
wmccarley commented on issue #10406:
URL: https://github.com/apache/pulsar/issues/10406#issuecomment-829291112
We use a lot of high-throughput non-persistent topics on our system for
streaming telemetry, it's useful for use cases where the overhead of tracking
message acknowledgement and r
eolivelli commented on a change in pull request #10428:
URL: https://github.com/apache/pulsar/pull/10428#discussion_r623130527
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AvroSchema.java
##
@@ -127,7 +127,12 @@ public static void addLogicalTy
LiPengze97 commented on issue #10406:
URL: https://github.com/apache/pulsar/issues/10406#issuecomment-829310879
> We use a lot of high-throughput non-persistent topics on our system for
streaming telemetry, it's useful for use cases where the overhead of tracking
message acknowledgement an
LiPengze97 commented on issue #10406:
URL: https://github.com/apache/pulsar/issues/10406#issuecomment-829311445
> yes, non-persistent topic doesn't persist messages so, it doesn't give
message delivery guarantee. it's used for usecases which only care about the
latest data and don't care a
SleeperSmith commented on issue #572:
URL: https://github.com/apache/pulsar/issues/572#issuecomment-829315109
Moving raft into Pulsar imo is like asking Wordpress to move mariadb into
its own code base. Strongly opposed to the idea as this is just wasting Pulsar
dev's time rewriting the ra
tomdavidson commented on issue #572:
URL: https://github.com/apache/pulsar/issues/572#issuecomment-829338113
> hope Pulsar devs don't make the same mistake Kafka did
I thought thats what Pulsar is :D
100% in agreement with @SleeperSmith ectd/consul/zk as plugable options
see
abhilashmandaliya commented on pull request #10441:
URL: https://github.com/apache/pulsar/pull/10441#issuecomment-829341578
/pulsarbot run-failure-checks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above t
codelipenghui merged pull request #10420:
URL: https://github.com/apache/pulsar/pull/10420
--
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,
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 bdb0990 [Transaction] Transaction log low water mark optimization.
(#10422)
add 345cd33 [Kinesis]Fix kinesis
merlimat commented on a change in pull request #10441:
URL: https://github.com/apache/pulsar/pull/10441#discussion_r623225368
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
##
@@ -197,6 +197,7 @@ private PulsarClientImpl(ClientCon
1 - 100 of 176 matches
Mail list logo