wolfstudy edited a comment on issue #3455: Acktimeout cannot be set in Go Client
URL: https://github.com/apache/pulsar/issues/3455#issuecomment-458027958
@tfhappy hello, I run the code you provided, and have the same problem, but
when I set the timeout time to 10s or more, this code works f
wolfstudy edited a comment on issue #3455: Acktimeout cannot be set in Go Client
URL: https://github.com/apache/pulsar/issues/3455#issuecomment-458027958
@tfhappy hello, I run the code you provided, and have the same problem, but
when I set the timeout time to 10s or more, this code works f
wolfstudy edited a comment on issue #3455: Acktimeout cannot be set in Go Client
URL: https://github.com/apache/pulsar/issues/3455#issuecomment-458027958
@tfhappy hello, I run the code you provided, and have the same problem, but
when I set the timeout time to 10s or more, this code works f
wolfstudy commented on issue #3455: Acktimeout cannot be set in Go Client
URL: https://github.com/apache/pulsar/issues/3455#issuecomment-458027958
@tfhappy hello, I run the code you provided, and have the same problem, but
when I set the timeout time to 10s or more, this code works fine.
JevonQ commented on issue #3230: expect not restart application after more
partitions created
URL: https://github.com/apache/pulsar/issues/3230#issuecomment-458024623
> @foreversunyao producers/consumers are not directly connected to ZK.
>
> We have on the roadmap to add support for
sijie commented on a change in pull request #3432: [Issue 3431] Support
Kafka-IO to pass extra configs
URL: https://github.com/apache/pulsar/pull/3432#discussion_r251299942
##
File path:
pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSinkConfig.java
##
@@ -
wolfstudy commented on issue #3443: [go-client] integrated `logrus`, `testify`
and `go mod` for pulsar-client-go
URL: https://github.com/apache/pulsar/pull/3443#issuecomment-458011920
@merlimat PTAL again, thanks
This is an a
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 95d02d5 Removed remaining import and usages of
merlimat merged pull request #3449: Removed remaining import and usages of
boost::shared_ptr
URL: https://github.com/apache/pulsar/pull/3449
This is an automated message from the Apache Git Service.
To respond to the message
jiazhai commented on issue #2659: Add backlog quota configuration on topic
URL: https://github.com/apache/pulsar/pull/2659#issuecomment-458004098
it seems that this PR would need address system topic first.
This is an automate
jiazhai closed issue #2877: Add integration test for KafkaConnectSource
URL: https://github.com/apache/pulsar/issues/2877
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitH
jiazhai commented on issue #2877: Add integration test for KafkaConnectSource
URL: https://github.com/apache/pulsar/issues/2877#issuecomment-458004405
PR #3154 was for this, and was closed
This is an automated message from the
jiazhai commented on issue #3062: [bookie] enable bookie http server
URL: https://github.com/apache/pulsar/pull/3062#issuecomment-458003763
retest this please
This is an automated message from the Apache Git Service.
To respo
jiazhai commented on issue #3413: Fix: init of subcription rateLimiter to avoid
race-condition and NPE
URL: https://github.com/apache/pulsar/pull/3413#issuecomment-458003593
@rdhabalia Thanks for the change. lgtm. but from the code, this looks like
a lazy creation, which could avoid crea
jiazhai commented on issue #3444: Fix REST API document link
URL: https://github.com/apache/pulsar/pull/3444#issuecomment-458002447
run integration tests
This is an automated message from the Apache Git Service.
To res
jiazhai commented on issue #3445: Add document for unloading namespace API
URL: https://github.com/apache/pulsar/pull/3445#issuecomment-458002668
run java8 tests
This is an automated message from the Apache Git Service.
To res
jiazhai commented on issue #3445: Add document for unloading namespace API
URL: https://github.com/apache/pulsar/pull/3445#issuecomment-458002637
run integration tests
This is an automated message from the Apache Git Service.
jiazhai commented on issue #3449: Removed remaining import and usages of
boost::shared_ptr
URL: https://github.com/apache/pulsar/pull/3449#issuecomment-457999566
run integration tests
This is an automated message from the Apa
tfhappy opened a new issue #3455: Acktimeout cannot be set in Go Client
URL: https://github.com/apache/pulsar/issues/3455
**Describe the bug**
When I create a consumer and specify acktimeout, I can't start it.
**To Reproduce**
```
package main
import (
"context"
murong00 commented on issue #3432: [Issue 3431] Support Kafka-IO to pass extra
configs
URL: https://github.com/apache/pulsar/pull/3432#issuecomment-457996405
@sijie @jiazhai PTAL, thanks!
This is an automated message from the
ConcurrencyPractitioner commented on issue #3450: Adding configuration to
disable auto-topic creation
URL: https://github.com/apache/pulsar/pull/3450#issuecomment-457994721
Ok, there are some kinks in my understanding. Wouldn't disabling
```createIfMissing``` also mean that no non-partiti
murong00 commented on a change in pull request #3432: [Issue 3431] Support
Kafka-IO to pass extra configs
URL: https://github.com/apache/pulsar/pull/3432#discussion_r251279178
##
File path: site2/docs/io-kafka.md
##
@@ -37,5 +38,6 @@ to a Kafka topic.
| batchSize | `true`
murong00 commented on a change in pull request #3432: [Issue 3431] Support
Kafka-IO to pass extra configs
URL: https://github.com/apache/pulsar/pull/3432#discussion_r251279252
##
File path:
pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java
##
murong00 commented on a change in pull request #3432: [Issue 3431] Support
Kafka-IO to pass extra configs
URL: https://github.com/apache/pulsar/pull/3432#discussion_r251279178
##
File path: site2/docs/io-kafka.md
##
@@ -37,5 +38,6 @@ to a Kafka topic.
| batchSize | `true`
jerrypeng merged pull request #3397: Exposing more methods in Sink/Source
Context
URL: https://github.com/apache/pulsar/pull/3397
This is an automated message from the Apache Git Service.
To respond to the message, please lo
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 ee25415 Exposing more methods in Sink/Source
ConcurrencyPractitioner edited a comment on issue #3450: Adding configuration
to disable auto-topic creation
URL: https://github.com/apache/pulsar/pull/3450#issuecomment-457945680
Ok, I did some digging and here's what I found:
```createIfMissing``` is used when seeing if a Z-Node is alr
jiazhai commented on issue #3449: Removed remaining import and usages of
boost::shared_ptr
URL: https://github.com/apache/pulsar/pull/3449#issuecomment-457990913
run integration tests
This is an automated message from the Apa
jiazhai commented on issue #3369: IndexOutOfBoundsException in kafka
ConsumerExample
URL: https://github.com/apache/pulsar/issues/3369#issuecomment-457989329
@ambition119 đź‘Ť . Would you like to help adding some comments in the code or
documentation for this issue?
-
tuteng commented on issue #3447: Running commands pulsar-admin source localrun
report class java.lang.NullPointerException: null
URL: https://github.com/apache/pulsar/issues/3447#issuecomment-457987244
Okay, I'll create a pr later.
--
jiazhai edited a comment on issue #3454: [Feature Request] Dynamically refresh
client after updating the number of partitions when the routing mode is not key
hash
URL: https://github.com/apache/pulsar/issues/3454#issuecomment-457986298
issue #3230 is related
-
jiazhai commented on issue #3454: [Feature Request] Dynamically refresh client
after updating the number of partitions when the routing mode is not key hash
URL: https://github.com/apache/pulsar/issues/3454#issuecomment-457986298
#3230 is related
---
merlimat merged pull request #3451: Fix incomplete documentation in
cookbooks-retention-expiry
URL: https://github.com/apache/pulsar/pull/3451
This is an automated message from the Apache Git Service.
To respond to the messa
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 2391503 Fix incomplete documentation in cookboo
jiazhai commented on issue #3447: Running commands pulsar-admin source localrun
report class java.lang.NullPointerException: null
URL: https://github.com/apache/pulsar/issues/3447#issuecomment-457984127
Thanks @tuteng for point it out, Would you like to solve this issue?
--
jiazhai commented on issue #3446: Support Time Index to support seeking based
on time in reader interface.
URL: https://github.com/apache/pulsar/issues/3446#issuecomment-457983741
Thanks for point out, this is a good feature to have.
--
merlimat commented on issue #3449: Removed remaining import and usages of
boost::shared_ptr
URL: https://github.com/apache/pulsar/pull/3449#issuecomment-457982864
run integration tests
This is an automated message from the Ap
merlimat merged pull request #3427: Add set python version script
URL: https://github.com/apache/pulsar/pull/3427
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and u
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 0446075 Add set python version script (#3427)
0
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 39e0f32 Update command usage for pulsar-perf cl
merlimat merged pull request #3452: Update command usage for pulsar-perf cli
command (#2895)
URL: https://github.com/apache/pulsar/pull/3452
This is an automated message from the Apache Git Service.
To respond to the message
ambition119 commented on a change in pull request #3434: [Issue 3390]
UncaughtExceptionLogsNOTWork
URL: https://github.com/apache/pulsar/pull/3434#discussion_r251270165
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/PulsarBrokerStarter.java
##
@@ -273,8 +277,
ambition119 commented on issue #3379: Issue #3378: [pulsar-io] Support Pulsar
to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#issuecomment-457977617
> overall looks good. left bunch of comments.
>
> Can you also add an integration test and a
wolfstudy commented on a change in pull request #3443: [go-client] integrated
`logrus`, `testify` and `go mod` for pulsar-client-go
URL: https://github.com/apache/pulsar/pull/3443#discussion_r251267255
##
File path: pulsar-client-go/examples/consumer-listener/consumer-listener.go
#
jerrypeng commented on issue #3397: Exposing more methods in Sink/Source Context
URL: https://github.com/apache/pulsar/pull/3397#issuecomment-457975537
rerun integration tests
This is an automated message from the Apache G
ambition119 commented on issue #3369: IndexOutOfBoundsException
URL: https://github.com/apache/pulsar/issues/3369#issuecomment-457975401
@jiazhai @sautran
org.apache.pulsar.client.kafka.compat.examples.ConsumerExample.java should
use pulsar shaded jar offered
[KafkaConsumer](https://
merlimat commented on issue #3452: Update command usage for pulsar-perf cli
command (#2895)
URL: https://github.com/apache/pulsar/pull/3452#issuecomment-457975203
run cpp tests
This is an automated message from the Apache Git
merlimat commented on issue #3451: Fix incomplete documentation in
cookbooks-retention-expiry
URL: https://github.com/apache/pulsar/pull/3451#issuecomment-457975083
run integration tests
This is an automated message from the
ambition119 commented on issue #3415: [pulsar-client] add BooleanSchema
URL: https://github.com/apache/pulsar/pull/3415#issuecomment-457972545
run integration tests
org.apache.pulsar.tests.integration.functions.PulsarFunctionsThreadTest.pulsar-test-suite
---
ConcurrencyPractitioner edited a comment on issue #3450: Adding configuration
to disable auto-topic creation
URL: https://github.com/apache/pulsar/pull/3450#issuecomment-457945680
Ok, I did some digging and here's what I found:
```createIfMissing``` is used when seeing if a Z-Node is alr
ConcurrencyPractitioner commented on issue #3450: Adding configuration to
disable auto-topic creation
URL: https://github.com/apache/pulsar/pull/3450#issuecomment-457945680
Ok, I did some digging and here's what I found:
```createIfMissing``` is used when seeing if a Z-Node is already bu
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 32e7f33 UncaughtExceptionLogsNOTWork (#3434)
32
merlimat closed issue #3390: pulsar-daemon start broker without setting
mandatory parameter failed without any errors
URL: https://github.com/apache/pulsar/issues/3390
This is an automated message from the Apache Git Service
merlimat merged pull request #3434: [Issue 3390] UncaughtExceptionLogsNOTWork
URL: https://github.com/apache/pulsar/pull/3434
This is an automated message from the Apache Git Service.
To respond to the message, please log on
merlimat merged pull request #3441: CPP Client - initialize flushedPartitions_
correctly and fix make tes…
URL: https://github.com/apache/pulsar/pull/3441
This is an automated message from the Apache Git Service.
To respond
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 eda414d CPP Client - initialize flushedPartitio
JevonQ opened a new issue #3454: [Feature Request] Dynamically refresh client
after updating the number of partitions when the routing mode is not key hash
URL: https://github.com/apache/pulsar/issues/3454
According to the web page (admin-api-partitioned-topics,
https://pulsar.apache.org/d
skyrocknroll opened a new issue #3453: Support subscribe position - initial or
latest in python client
URL: https://github.com/apache/pulsar/issues/3453
**Is your feature request related to a problem? Please describe.**
The subscribe method in python client does not support
Subscriptio
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 96fdfd0 Updated site at revision 762e0ab
96
MarvinCai opened a new pull request #3452: Update command usage for pulsar-perf
cli command (#2895)
URL: https://github.com/apache/pulsar/pull/3452
### Motivation
Fix for issue: #2895
### Changes
As all required argument already have required flag for JCommander, update
the do
jiazhai merged pull request #3312: Prevent dup consumers on same client cnx
with shared subscription
URL: https://github.com/apache/pulsar/pull/3312
This is an automated message from the Apache Git Service.
To respond to the
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 231db03 Prevent dup consumers on same client c
62 matches
Mail list logo
