Anonymitaet commented on a change in pull request #5210: [Doc] Add *Kafka sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5210#discussion_r325500185
##
File path: site2/docs/io-kafka-sink.md
##
@@ -0,0 +1,66 @@
+---
+id: io-kafka-sink
+title: Kafka sink co
Anonymitaet commented on a change in pull request #5210: [Doc] Add *Kafka sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5210#discussion_r325500145
##
File path: site2/docs/io-kafka-sink.md
##
@@ -0,0 +1,66 @@
+---
+id: io-kafka-sink
+title: Kafka sink co
tuteng commented on a change in pull request #5210: [Doc] Add *Kafka sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5210#discussion_r325499228
##
File path: site2/docs/io-kafka-sink.md
##
@@ -0,0 +1,66 @@
+---
+id: io-kafka-sink
+title: Kafka sink connect
tuteng commented on a change in pull request #5210: [Doc] Add *Kafka sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5210#discussion_r325498483
##
File path: site2/docs/io-kafka-sink.md
##
@@ -0,0 +1,66 @@
+---
+id: io-kafka-sink
+title: Kafka sink connect
tuteng commented on issue #5197: [Doc] Update *Debezium Connector Guide*
URL: https://github.com/apache/pulsar/pull/5197#issuecomment-532535767
LGTM
This is an automated message from the Apache Git Service.
To respond to the m
tuteng commented on issue #5197: [Doc] Update *Debezium Connector Guide*
URL: https://github.com/apache/pulsar/pull/5197#issuecomment-532535862
run integration tests
This is an automated message from the Apache Git Service.
To
sijie commented on issue #5136: Java Function cannot work with any JSON parser
JAR
URL: https://github.com/apache/pulsar/issues/5136#issuecomment-532515588
the original `AddWindowFunction` example is `Function ,
Integer>`. If you run this function before, the input topic and output topic
sijie commented on issue #5134: [Documentation] Add Geo Replicated
subscriptions documentation in website
URL: https://github.com/apache/pulsar/issues/5134#issuecomment-532514096
@Jennifer88huang can you add this to the backlog? It is good to have this
documentation added before 2.5.0 rele
Anonymitaet edited a comment on issue #5203: [Doc] Add *Kafka source connector
guide*
URL: https://github.com/apache/pulsar/pull/5203#issuecomment-532511838
@murong00 I've added separate guides for both Kafka source connector (this
PR) and Kafka sink connector (https://github.com/apache/pu
Anonymitaet commented on a change in pull request #5203: [Doc] Add *Kafka
source connector guide*
URL: https://github.com/apache/pulsar/pull/5203#discussion_r325477038
##
File path: site2/docs/io-kafka-source.md
##
@@ -0,0 +1,170 @@
+---
+id: io-kafka-source
+title: Kafka
sijie commented on issue #5207: Fixed flaky tests in ReplicatorRateLimiterTest
URL: https://github.com/apache/pulsar/pull/5207#issuecomment-532511991
run cpp tests
run integration tests
run java8 tests
This is an automat
Anonymitaet commented on issue #5203: [Doc] Add *Kafka source connector guide*
URL: https://github.com/apache/pulsar/pull/5203#issuecomment-532511838
@murong00 I've added separate guides for both Kafka source connector (this
PR) and Kafka sink connector (https://github.com/apache/pulsar/pul
murong00 commented on a change in pull request #5210: [Doc] Add *Kafka sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5210#discussion_r325475300
##
File path: site2/docs/io-kafka-sink.md
##
@@ -0,0 +1,66 @@
+---
+id: io-kafka-sink
+title: Kafka sink conne
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 871a1e0 Ensure getting list of topics for namespace is handled
asynchronously (#5188)
add 7515634 Ensure consu
sijie merged pull request #5204: Ensure consumer background tasks are cancelled
after subscribe failures
URL: https://github.com/apache/pulsar/pull/5204
This is an automated message from the Apache Git Service.
To respond to
sijie closed issue #4926: Add more config for auto-topic-creation
URL: https://github.com/apache/pulsar/issues/4926
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
sijie commented on issue #4926: Add more config for auto-topic-creation
URL: https://github.com/apache/pulsar/issues/4926#issuecomment-532508709
Fixed by #4963
This is an automated message from the Apache Git Service.
To respo
addisonj commented on issue #4926: Add more config for auto-topic-creation
URL: https://github.com/apache/pulsar/issues/4926#issuecomment-532504100
This looks to be all fixed now? Seems like this should be closed
This is an au
Anonymitaet commented on a change in pull request #5210: [Doc] Add *Kafka sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5210#discussion_r325467954
##
File path: site2/docs/io-kafka-sink.md
##
@@ -0,0 +1,66 @@
+---
+id: io-kafka-sink
+title: Kafka sink co
Anonymitaet commented on a change in pull request #5210: [Doc] Add *Kafka sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5210#discussion_r325467829
##
File path: site2/docs/io-kafka-sink.md
##
@@ -0,0 +1,66 @@
+---
+id: io-kafka-sink
+title: Kafka sink co
Anonymitaet commented on a change in pull request #5210: [Doc] Add *Kafka sink
connector guide*
URL: https://github.com/apache/pulsar/pull/5210#discussion_r325467749
##
File path: site2/docs/io-kafka-sink.md
##
@@ -0,0 +1,66 @@
+---
+id: io-kafka-sink
+title: Kafka sink co
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524149120
PRs related to this issue:
## Overview
* https://github.com/apache/pulsar/pull/5183
## Use
* https://github.com/apach
Anonymitaet opened a new pull request #5210: [Doc] Add *Kafka sink connector
guide*
URL: https://github.com/apache/pulsar/pull/5210
Fix https://github.com/apache/pulsar/issues/5015
This is an automated message from the Apache
Anonymitaet commented on issue #5135: [doc] Improve Pulsar deployment bare
metal multi cluster
URL: https://github.com/apache/pulsar/pull/5135#issuecomment-532499906
@Monica-zy could you please resolve the conflict?
This is a
congbobo184 commented on issue #5123: Modify the schema decode method can
decode ByteBuf
URL: https://github.com/apache/pulsar/pull/5123#issuecomment-532497271
run java8 tests
This is an automated message from the Apache Git
pouledodue commented on issue #5209: HTTP 500 on pulsar-admin schemas delete
URL: https://github.com/apache/pulsar/issues/5209#issuecomment-532491944
only the INFO:
```
02:27:53.015 [BookKeeperClientWorker-OrderedExecutor-0-0] INFO
org.eclipse.jetty.server.RequestLog - 172.17.0
pouledodue commented on issue #5209: HTTP 500 on pulsar-admin schemas delete
URL: https://github.com/apache/pulsar/issues/5209#issuecomment-532491390
no stack trace with `docker logs` and no stack trace in
`logs/pulsar-standalone.log` is there a log file I missed?
-
pouledodue commented on issue #5208: Schema modification question
URL: https://github.com/apache/pulsar/issues/5208#issuecomment-532490748
great
This is an automated message from the Apache Git Service.
To respond to the messa
stupidusername commented on issue #5208: Schema modification question
URL: https://github.com/apache/pulsar/issues/5208#issuecomment-532489970
I don't think `deleted` it's the right field name to indicate that the
schema is no longer in use. Messages created before the schema was deleted wi
merlimat commented on issue #5209: HTTP 500 on pulsar-admin schemas delete
URL: https://github.com/apache/pulsar/issues/5209#issuecomment-532489437
500 is typically associated with an exception stack trace on broker side.
Can you paste that as well?
pouledodue commented on issue #5088: can't update JSON Schema to AVRO with
pulsar-admin
URL: https://github.com/apache/pulsar/issues/5088#issuecomment-532489197
yes it's ok when I delete it before
This is an automated message
pouledodue opened a new issue #5209: HTTP 500 on pulsar-admin schemas delete
URL: https://github.com/apache/pulsar/issues/5209
when there is no schema to delete the command
`pulsar-admin schemas delete persistent://a/b/c`
gives:
HTTP 500 Internal Server Error
Should prob
stupidusername commented on issue #5088: can't update JSON Schema to AVRO with
pulsar-admin
URL: https://github.com/apache/pulsar/issues/5088#issuecomment-532488195
Have you tried deleting the schema before changing its type?
```
$ pulsar-admin schemas delete persistent://public/d
pouledodue opened a new issue #5208: Schema modification question
URL: https://github.com/apache/pulsar/issues/5208
I delete a schema:
`pulsar-admin schemas delete persistent://a/b/c`
I verify it is deleted:
`pulsar-admin schemas get persistent://a/b/c`
`> HTTP 404 Not Found
Anonymitaet commented on a change in pull request #5203: [Doc] Add *Kafka
source connector guide*
URL: https://github.com/apache/pulsar/pull/5203#discussion_r325195015
##
File path: site2/docs/io-kafka-source.md
##
@@ -0,0 +1,170 @@
+---
+id: io-kafka-source
+title: Kafka
pouledodue closed issue #5088: can't update JSON Schema to AVRO with
pulsar-admin
URL: https://github.com/apache/pulsar/issues/5088
This is an automated message from the Apache Git Service.
To respond to the message, please
merlimat commented on issue #5207: Fixed flaky tests in
ReplicatorRateLimiterTest
URL: https://github.com/apache/pulsar/pull/5207#issuecomment-532466891
rerun tests please
This is an automated message from the Apache Git Serv
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 871a1e0 Ensure getting list of topics for names
merlimat merged pull request #5188: Ensure getting list of topics for namespace
is handled asynchronously
URL: https://github.com/apache/pulsar/pull/5188
This is an automated message from the Apache Git Service.
To respond t
merlimat commented on issue #5188: Ensure getting list of topics for namespace
is handled asynchronously
URL: https://github.com/apache/pulsar/pull/5188#issuecomment-532440770
run cpp tests
This is an automated messag
merlimat commented on issue #5205: [doc] Fix broken links to the info about
schemas and Schema Registry
URL: https://github.com/apache/pulsar/pull/5205#issuecomment-532422188
run java8 tests
run integration tests
This is a
merlimat commented on issue #5188: Ensure getting list of topics for namespace
is handled asynchronously
URL: https://github.com/apache/pulsar/pull/5188#issuecomment-532421686
run cpp tests
This is an automated message from t
iravishah commented on issue #5206: TooLongFrameException : Adjusted frame
length exceeds 5253120: 369295620 - discarded => Error while producing message
with TLS on standalone setup
URL: https://github.com/apache/pulsar/issues/5206#issuecomment-532413982
yes, I am using the same url.
p
merlimat commented on issue #5204: Ensure consumer background tasks are
cancelled after subscribe failures
URL: https://github.com/apache/pulsar/pull/5204#issuecomment-532412637
run java8 tests
This is an automated message fr
merlimat commented on issue #5206: TooLongFrameException : Adjusted frame
length exceeds 5253120: 369295620 - discarded => Error while producing message
with TLS on standalone setup
URL: https://github.com/apache/pulsar/issues/5206#issuecomment-532412421
This looks like you're trying to co
merlimat opened a new pull request #5207: Fixed flaky tests in
ReplicatorRateLimiterTest
URL: https://github.com/apache/pulsar/pull/5207
### Motivation
ReplicatorRateLimiterTest is failing from time to time. The 5 secs timeout
is possibly too short when running on the shared Jenkins
iravishah opened a new issue #5206: TooLongFrameException : Adjusted frame
length exceeds 5253120: 369295620 - discarded => Error while producing message
with TLS on standalone setup
URL: https://github.com/apache/pulsar/issues/5206
I am using apache pulsar 2.4.0 on standalone setup on ubu
vzhikserg opened a new pull request #5205: [doc] Fix broken links to the info
about schemas and Schema Registry
URL: https://github.com/apache/pulsar/pull/5205
In the latest version of the documentation, I found a broken link to the
concepts about Schema Registry. It seems that this markdo
merlimat opened a new pull request #5204: Ensure consumer background tasks are
cancelled after subscribe failures
URL: https://github.com/apache/pulsar/pull/5204
### Motivation
Some of the background consumer tasks are being started in the
`ConsumerImpl` constructor though these are
merlimat commented on issue #5188: Ensure getting list of topics for namespace
is handled asynchronously
URL: https://github.com/apache/pulsar/pull/5188#issuecomment-532303407
run java8 tests
run integration tests
This is
Jennifer88huang commented on issue #4963: Add more config for
auto-topic-creation
URL: https://github.com/apache/pulsar/pull/4963#issuecomment-532246013
Got it.
This is an automated message from the Apache Git Service.
To res
Anonymitaet commented on a change in pull request #5203: [Doc] Add *Kafka
source connector guide*
URL: https://github.com/apache/pulsar/pull/5203#discussion_r325195015
##
File path: site2/docs/io-kafka-source.md
##
@@ -0,0 +1,170 @@
+---
+id: io-kafka-source
+title: Kafka
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524149120
PRs related to this issue:
## Overview
* https://github.com/apache/pulsar/pull/5183
## Use
* https://github.com/apach
Anonymitaet opened a new pull request #5203: [Doc] Add *Kafka source connector
guide*
URL: https://github.com/apache/pulsar/pull/5203
Fix https://github.com/apache/pulsar/issues/5015
This is an automated message from the Apac
This is an automated email from the ASF dual-hosted git repository.
sijie 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 f3d37d0 [Doc] Update *Develop Connectors Guide*
sijie merged pull request #5181: [Doc] Update *Develop Connectors Guide*
URL: https://github.com/apache/pulsar/pull/5181
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
sijie commented on issue #4932: Functions BC issue with 2.3.1 client in regards
to resources
URL: https://github.com/apache/pulsar/pull/4932#issuecomment-532234866
run java8 tests
This is an automated message from the Apache
sijie commented on issue #4963: Add more config for auto-topic-creation
URL: https://github.com/apache/pulsar/pull/4963#issuecomment-532234573
@jiazhai @Jennifer88huang can you please make sure this feature is well
documented?
---
sijie merged pull request #4963: Add more config for auto-topic-creation
URL: https://github.com/apache/pulsar/pull/4963
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
This is an automated email from the ASF dual-hosted git repository.
sijie 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 547c421 Add more config for auto-topic-creation
This is an automated email from the ASF dual-hosted git repository.
sijie 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 6df8d40 [doc] Improve Pulsar deployment bare met
sijie merged pull request #5111: [doc] Improve Pulsar deployment bare metal
URL: https://github.com/apache/pulsar/pull/5111
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 627e6f8 [Doc] Update Canal source connector guide (#5173)
add c8ddbdd [doc] Improve Pulsar multi-cluster deploy
sijie merged pull request #5167: [doc] Improve Pulsar multi-cluster deployment
URL: https://github.com/apache/pulsar/pull/5167
This is an automated message from the Apache Git Service.
To respond to the message, please log on
This is an automated email from the ASF dual-hosted git repository.
sijie 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 627e6f8 [Doc] Update Canal source connector guid
sijie merged pull request #5173: [Doc] Update Canal source connector guide
URL: https://github.com/apache/pulsar/pull/5173
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
This is an automated email from the ASF dual-hosted git repository.
sijie 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 26df3e7 [Doc] Update *Overview of Connector* (#5
sijie merged pull request #5183: [Doc] Update *Overview of Connector*
URL: https://github.com/apache/pulsar/pull/5183
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from f844507 Added missing enum value KeyShared on python wrapper (#5196)
add 94d6911 [Doc] Update *CDC connector gu
sijie merged pull request #5198: [Doc] Update *CDC connector guide*
URL: https://github.com/apache/pulsar/pull/5198
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
codelipenghui commented on issue #5202: Incorrect msgBacklog value
URL: https://github.com/apache/pulsar/issues/5202#issuecomment-532174311
Seems like a bug which i see different subscription with same mark delete
position but different delete count.
@shustsud If you are interested
Anonymitaet commented on issue #5199: [Doc] Add configuration of Flume source
connector
URL: https://github.com/apache/pulsar/pull/5199#issuecomment-532152141
@tuteng I've incorporated your comment, could you PTAL?
This is an
Anonymitaet commented on issue #5197: [Doc] Update *Debezium Connector Guide*
URL: https://github.com/apache/pulsar/pull/5197#issuecomment-532151296
@tuteng I've incorporated all your comments, could you PTAL?
This is an autom
Jennifer88huang commented on a change in pull request #5201: [Issue 5050][Docs]
Adjust the content structure of the security chapter
URL: https://github.com/apache/pulsar/pull/5201#discussion_r325053669
##
File path: site2/docs/security-jwt.md
##
@@ -0,0 +1,243 @@
+---
+i
Jennifer88huang commented on a change in pull request #5201: [Issue 5050][Docs]
Adjust the content structure of the security chapter
URL: https://github.com/apache/pulsar/pull/5201#discussion_r325054561
##
File path: site2/docs/security-jwt.md
##
@@ -0,0 +1,243 @@
+---
+i
Jennifer88huang commented on a change in pull request #5201: [Issue 5050][Docs]
Adjust the content structure of the security chapter
URL: https://github.com/apache/pulsar/pull/5201#discussion_r325050417
##
File path: site2/docs/security-jwt.md
##
@@ -0,0 +1,243 @@
+---
+i
Jennifer88huang commented on a change in pull request #5201: [Issue 5050][Docs]
Adjust the content structure of the security chapter
URL: https://github.com/apache/pulsar/pull/5201#discussion_r325052277
##
File path: site2/docs/security-jwt.md
##
@@ -0,0 +1,243 @@
+---
+i
Jennifer88huang commented on a change in pull request #5201: [Issue 5050][Docs]
Adjust the content structure of the security chapter
URL: https://github.com/apache/pulsar/pull/5201#discussion_r325051249
##
File path: site2/docs/security-jwt.md
##
@@ -0,0 +1,243 @@
+---
+i
Jennifer88huang commented on a change in pull request #5201: [Issue 5050][Docs]
Adjust the content structure of the security chapter
URL: https://github.com/apache/pulsar/pull/5201#discussion_r325053148
##
File path: site2/docs/security-jwt.md
##
@@ -0,0 +1,243 @@
+---
+i
Jennifer88huang commented on a change in pull request #5201: [Issue 5050][Docs]
Adjust the content structure of the security chapter
URL: https://github.com/apache/pulsar/pull/5201#discussion_r325053195
##
File path: site2/docs/security-jwt.md
##
@@ -0,0 +1,243 @@
+---
+i
Jennifer88huang commented on a change in pull request #5201: [Issue 5050][Docs]
Adjust the content structure of the security chapter
URL: https://github.com/apache/pulsar/pull/5201#discussion_r325051095
##
File path: site2/docs/security-jwt.md
##
@@ -0,0 +1,243 @@
+---
+i
Jennifer88huang commented on issue #5167: [doc] Improve Pulsar multi-cluster
deployment
URL: https://github.com/apache/pulsar/pull/5167#issuecomment-532124211
run integration tests
run java8 tests
This is an automated mess
Jennifer88huang commented on a change in pull request #5201: [Issue 5050][Docs]
Adjust the content structure of the security chapter
URL: https://github.com/apache/pulsar/pull/5201#discussion_r325046390
##
File path: site2/docs/security-overview.md
##
@@ -10,26 +10,27 @@
Jennifer88huang commented on issue #5111: [doc] Improve Pulsar deployment bare
metal
URL: https://github.com/apache/pulsar/pull/5111#issuecomment-532120662
run java8 tests
This is an automated message from the Apache Git Serv
shustsud opened a new issue #5202: Incorrect msgBacklog value
URL: https://github.com/apache/pulsar/issues/5202
**Describe the bug**
Despite there are no messages in the backlog, positive value was set to
"msgBacklog" in the response of partitioned-stats(API).
I think "msgBacklog"
yittg commented on a change in pull request #5165: [PIP-43] Support producer to
send msg with different schema
URL: https://github.com/apache/pulsar/pull/5165#discussion_r325024160
##
File path:
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java
Monica-zy opened a new pull request #5201: [Issue 5050][Docs] Adjust the
content structure of the security chapter
URL: https://github.com/apache/pulsar/pull/5201
Fix #5050 #5166
Motivation
add the corresponded reference content of 'JSON Web Token Authentication'
link in the Securi
yittg commented on a change in pull request #5165: [PIP-43] Support producer to
send msg with different schema
URL: https://github.com/apache/pulsar/pull/5165#discussion_r325015192
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/SchemaHash.java
#
yittg commented on a change in pull request #5165: [PIP-43] Support producer to
send msg with different schema
URL: https://github.com/apache/pulsar/pull/5165#discussion_r325015007
##
File path:
pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleSchemaTest.java
###
yittg commented on a change in pull request #5165: [PIP-43] Support producer to
send msg with different schema
URL: https://github.com/apache/pulsar/pull/5165#discussion_r325014856
##
File path:
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerMultiSchemaMode.ja
yittg commented on a change in pull request #5165: [PIP-43] Support producer to
send msg with different schema
URL: https://github.com/apache/pulsar/pull/5165#discussion_r325014623
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java
###
vicaya opened a new issue #5200: Broker high cpu usage under light load
URL: https://github.com/apache/pulsar/issues/5200
**Describe the bug**
All 3 of the brokers in a cluster gradually consume ~3 cores/vcpus (per
broker) and went into load balancing mode (according to the broker log, i
Monica-zy closed pull request #5166: [Issue 5050][docs] Adjust the content
structure of the security chapter
URL: https://github.com/apache/pulsar/pull/5166
This is an automated message from the Apache Git Service.
To respon
Monica-zy commented on issue #5135: [doc] Improve Pulsar deployment bare metal
multi cluster
URL: https://github.com/apache/pulsar/pull/5135#issuecomment-532088817
run integration tests
This is an automated message from the A
94 matches
Mail list logo