murong00 opened a new pull request #3387: [docs] Fix several typos in Kafka
Wrapper
URL: https://github.com/apache/pulsar/pull/3387
### Motivation
Kafka Wrapper doc minor improvement.
### Modifications
Amend several typos in Kafka Wrapper.
ambition119 commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248911596
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java
david-streamlio commented on a change in pull request #3379: Issue #3378:
[pulsar-io] Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248946777
##
File path:
david-streamlio commented on a change in pull request #3379: Issue #3378:
[pulsar-io] Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248946530
##
File path:
david-streamlio commented on a change in pull request #3379: Issue #3378:
[pulsar-io] Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248946368
##
File path:
ambition119 commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248911596
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java
david-streamlio 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-455446766
FWIW, I have create Pulsar Processors for Apache NiFi.
david-streamlio commented on a change in pull request #3379: Issue #3378:
[pulsar-io] Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248943754
##
File path:
david-streamlio commented on a change in pull request #3379: Issue #3378:
[pulsar-io] Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248943619
##
File path:
jerrypeng commented on issue #3383: refactor AuthorizationProvider interface
to allow custom logic for determining super user
URL: https://github.com/apache/pulsar/pull/3383#issuecomment-455424618
rerun integration tests
jerrypeng commented on issue #3384: fix get topic name for python functions
when subscribing from regex topic
URL: https://github.com/apache/pulsar/pull/3384#issuecomment-455424471
rerun java8 tests
This is an automated
ambition119 commented on a change in pull request #3379: Issue #3378:
[pulsar-io] Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248925224
##
File path:
ambition119 commented on a change in pull request #3379: Issue #3378:
[pulsar-io] Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248924143
##
File path:
ambition119 commented on a change in pull request #3379: Issue #3378:
[pulsar-io] Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248924172
##
File path:
ambition119 commented on a change in pull request #3379: Issue #3378:
[pulsar-io] Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248923756
##
File path:
JevonQ edited a comment on issue #386: Partitions in partitioned topic should
be automatically distributed to multiple brokers
URL: https://github.com/apache/pulsar/issues/386#issuecomment-455147566
@merlimat Since there are several thresholds to control the split on the
bundle, so there
jiazhai edited a comment 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-455190919
@ambition119 , Thanks a lot for the help. If it is available, it would be
better to add some
jiazhai commented on issue #3381: [Issue 3364][pulsar-client-tools] Support CLI
pulsar-client for concise description
URL: https://github.com/apache/pulsar/pull/3381#issuecomment-455409486
run integration tests
This is an
ambition119 commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248911596
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java
ambition119 commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248911596
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java
ambition119 commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248902477
##
File path: pulsar-io/hbase/pom.xml
##
@@ -0,0 +1,94 @@
+
+http://maven.apache.org/POM/4.0.0;
+
merlimat commented on issue #3381: [Issue 3364][pulsar-client-tools] Support
CLI pulsar-client for concise description
URL: https://github.com/apache/pulsar/pull/3381#issuecomment-455398800
run integration tests
This is an
rdhabalia opened a new pull request #3386: [cpp-build] support run specific
cpp-test using docker build script
URL: https://github.com/apache/pulsar/pull/3386
### Modifications
Provide a option to run specific cpp-test in docker test-run script.
ambition119 commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248902477
##
File path: pulsar-io/hbase/pom.xml
##
@@ -0,0 +1,94 @@
+
+http://maven.apache.org/POM/4.0.0;
+
ambition119 commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248903122
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseSinkConfig.java
ambition119 commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248903107
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/HbaseAbstractConfig.java
##
ambition119 commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248902896
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/HbaseAbstractConfig.java
##
ambition119 commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248902758
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/HbaseAbstractConfig.java
##
ambition119 commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248902477
##
File path: pulsar-io/hbase/pom.xml
##
@@ -0,0 +1,94 @@
+
+http://maven.apache.org/POM/4.0.0;
+
ambition119 commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248902448
##
File path: pulsar-io/hbase/pom.xml
##
@@ -0,0 +1,94 @@
+
+http://maven.apache.org/POM/4.0.0;
+
ambition119 commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248902448
##
File path: pulsar-io/hbase/pom.xml
##
@@ -0,0 +1,94 @@
+
+http://maven.apache.org/POM/4.0.0;
+
jerrypeng commented on a change in pull request #3383: refactor
AuthorizationProvider interface to allow custom logic for determining super user
URL: https://github.com/apache/pulsar/pull/3383#discussion_r248902427
##
File path:
ivankelly commented on a change in pull request #3383: refactor
AuthorizationProvider interface to allow custom logic for determining super user
URL: https://github.com/apache/pulsar/pull/3383#discussion_r248901944
##
File path:
rdhabalia opened a new pull request #3385: [cpp-build] add argument to cpp
incremental build
URL: https://github.com/apache/pulsar/pull/3385
### Motivation
Provide a way to build pulsar-cpp client with incremental build option to
avoid building it entirely and save build time.
jerrypeng commented on a change in pull request #3383: refactor
AuthorizationProvider interface to allow custom logic for determining super user
URL: https://github.com/apache/pulsar/pull/3383#discussion_r248886424
##
File path:
sijie commented on issue #3381: [Issue 3364][pulsar-client-tools] Support CLI
pulsar-client for concise description
URL: https://github.com/apache/pulsar/pull/3381#issuecomment-455375581
run integration tests
This is an
sijie commented on a change in pull request #3383: refactor
AuthorizationProvider interface to allow custom logic for determining super user
URL: https://github.com/apache/pulsar/pull/3383#discussion_r248884418
##
File path:
jerrypeng commented on issue #3383: refactor AuthorizationProvider interface
to allow custom logic for determining super user
URL: https://github.com/apache/pulsar/pull/3383#issuecomment-455374573
@ivankelly thanks for the review! I have addressed your comments
jerrypeng commented on a change in pull request #3383: refactor
AuthorizationProvider interface to allow custom logic for determining super user
URL: https://github.com/apache/pulsar/pull/3383#discussion_r248884008
##
File path:
jerrypeng commented on a change in pull request #3383: refactor
AuthorizationProvider interface to allow custom logic for determining super user
URL: https://github.com/apache/pulsar/pull/3383#discussion_r248882771
##
File path:
jerrypeng commented on a change in pull request #3383: refactor
AuthorizationProvider interface to allow custom logic for determining super user
URL: https://github.com/apache/pulsar/pull/3383#discussion_r248882747
##
File path:
jerrypeng opened a new pull request #3384: fix get topic name for python
functions when subscribing from regex topic
URL: https://github.com/apache/pulsar/pull/3384
### Motivation
After adding support for getting the topic name from a message for the
python pulsar client API, we
ivankelly commented on a change in pull request #3383: refactor
AuthorizationProvider interface to allow custom logic for determining super user
URL: https://github.com/apache/pulsar/pull/3383#discussion_r248860762
##
File path:
ivankelly commented on a change in pull request #3383: refactor
AuthorizationProvider interface to allow custom logic for determining super user
URL: https://github.com/apache/pulsar/pull/3383#discussion_r248859661
##
File path:
jerrypeng opened a new pull request #3383: refactor AuthorizationProvider
interface to allow custom logic for determining super user
URL: https://github.com/apache/pulsar/pull/3383
### Motivation
Currently the logic for determining if a role is a super user is not
pluggable.
aahmed-se opened a new pull request #2872: Update to use use new vagrant images
URL: https://github.com/apache/pulsar/pull/2872
We are updating the osx build to use new optimized vm images with pre
installed dev tools , brew and associated build packages. The calling script
can now link
joefk commented on issue #3376: Add ability to connect to bookkeeper using tls
URL: https://github.com/apache/pulsar/issues/3376#issuecomment-455269678
This is an automated message from the Apache Git Service.
To respond
kamal-brill opened a new issue #3382: What's purpose of ackId when publishing
to a topic ?
URL: https://github.com/apache/pulsar/issues/3382
**Describe the bug**
When we publish the message to a topic, it returns an `ackId`. What's the
purpose of that `ackId` ? Can we use it to
sijie commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248711013
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseSinkConfig.java
##
@@
sijie commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248713240
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java
##
sijie commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248713654
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseGenericRecordSink.java
sijie commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248713349
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java
##
sijie commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248712000
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java
##
sijie commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248712974
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java
##
sijie commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248711120
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseSinkConfig.java
##
@@
sijie commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248709697
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/HbaseAbstractConfig.java
##
@@
sijie commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248710535
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseSinkConfig.java
##
@@
sijie commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248708289
##
File path: pulsar-io/hbase/pom.xml
##
@@ -0,0 +1,94 @@
+
+http://maven.apache.org/POM/4.0.0;
+
sijie commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248712430
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java
##
sijie commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248709079
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/HbaseAbstractConfig.java
##
@@
sijie commented on a change in pull request #3368: Issue #3290 Pulsar IO
connector for Hbase sink
URL: https://github.com/apache/pulsar/pull/3368#discussion_r248708863
##
File path:
pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/HbaseAbstractConfig.java
##
@@
ambition119 edited a comment on issue #3375: Websocket example not working -
Throwing Unexpected server response: 500
URL: https://github.com/apache/pulsar/issues/3375#issuecomment-455201089
In addition to the create, tenant, namespace has to be able to be used by
standalone.
```shell
ambition119 edited a comment on issue #3375: Websocket example not working -
Throwing Unexpected server response: 500
URL: https://github.com/apache/pulsar/issues/3375#issuecomment-455201089
In addition to the create, tenant, namespace has to be able to be used by
standalone.
```shell
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 d1b8f94 Java Client - Prevent printing
sijie merged pull request #3377: Java Client - Prevent printing authentication
data in INFO logs.
URL: https://github.com/apache/pulsar/pull/3377
This is an automated message from the Apache Git Service.
To respond to the
sijie commented on issue #3381: [Issue 3364][pulsar-client-tools] Support CLI
pulsar-client for concise description
URL: https://github.com/apache/pulsar/pull/3381#issuecomment-455202228
run integration tests
This is an
sijie commented on a change in pull request #3379: Issue #3378: [pulsar-io]
Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248600875
##
File path: pulsar-io/nifi/pom.xml
##
@@ -0,0 +1,83 @@
+
sijie commented on a change in pull request #3379: Issue #3378: [pulsar-io]
Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248700532
##
File path:
sijie commented on a change in pull request #3379: Issue #3378: [pulsar-io]
Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248600744
##
File path: distribution/io/src/assemble/io.xml
##
@@ -105,5
sijie commented on a change in pull request #3379: Issue #3378: [pulsar-io]
Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248703038
##
File path:
sijie commented on a change in pull request #3379: Issue #3378: [pulsar-io]
Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248701799
##
File path:
ambition119 edited a comment on issue #3375: Websocket example not working -
Throwing Unexpected server response: 500
URL: https://github.com/apache/pulsar/issues/3375#issuecomment-455201089
In addition to the create, namespace has to be able to be used by standalone.
```shell
$
sijie commented on a change in pull request #3379: Issue #3378: [pulsar-io]
Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248700866
##
File path:
sijie commented on a change in pull request #3379: Issue #3378: [pulsar-io]
Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248603168
##
File path:
sijie commented on a change in pull request #3379: Issue #3378: [pulsar-io]
Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248700424
##
File path:
sijie commented on a change in pull request #3379: Issue #3378: [pulsar-io]
Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248680343
##
File path:
sijie commented on a change in pull request #3379: Issue #3378: [pulsar-io]
Support Pulsar to receive and send data from Apache NiFi
URL: https://github.com/apache/pulsar/pull/3379#discussion_r248603926
##
File path:
ambition119 commented on issue #3375: Websocket example not working - Throwing
Unexpected server response: 500
URL: https://github.com/apache/pulsar/issues/3375#issuecomment-455201089
In addition to the create, namespace has to be able to be used by standalone.
```shell
$ bin/pulsar
jiazhai 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-455190919
@ambition119 , Thanks a lot for the help. It would be better to add some
documentation and
jiazhai edited a comment on issue #3367: Dashboard docker shows no data
URL: https://github.com/apache/pulsar/issues/3367#issuecomment-455187883
@foreversunyao, thanks for the help. Yes, it use admin api to get the stats.
Confirmed with one usr that reported a similar issue, this could
jiazhai commented on issue #3367: Dashboard docker shows no data
URL: https://github.com/apache/pulsar/issues/3367#issuecomment-455187883
@foreversunyao asked one usr that reported a similar issue, this could be
fixed by setting advertisedAddress for both `broker.conf` and
JevonQ commented on issue #386: Partitions in partitioned topic should be
automatically distributed to multiple brokers
URL: https://github.com/apache/pulsar/issues/386#issuecomment-455147566
Since there are several thresholds to control the split on the bundle, so
there is one scenario
sijie commented on issue #3376: Add ability to connect to bookkeeper using tls
URL: https://github.com/apache/pulsar/issues/3376#issuecomment-455108331
@bputt gotcha, thank you for clarification.
This is an automated message
sijie commented on a change in pull request #3365:
create_topic_with_check_namespaces_cluster
URL: https://github.com/apache/pulsar/pull/3365#discussion_r248599954
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
##
@@
foreversunyao commented on issue #3365:
create_topic_with_check_namespaces_cluster
URL: https://github.com/apache/pulsar/pull/3365#issuecomment-455104900
@merlimat , will add a unit test for this change
This is an automated
foreversunyao commented on a change in pull request #3365:
create_topic_with_check_namespaces_cluster
URL: https://github.com/apache/pulsar/pull/3365#discussion_r248596095
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
##
murong00 opened a new pull request #3381: [Issue 3364][pulsar-client-tools]
Support CLI pulsar-client for concise description
URL: https://github.com/apache/pulsar/pull/3381
### Motivation
Fixes [#3364](https://github.com/apache/pulsar/issues/3364)
### Modifications
Print
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-455083822
run integration tests
This is an
88 matches
Mail list logo
