[GitHub] liketic commented on issue #3338: Remove global zookeeper option in code base

2019-01-11 Thread GitBox
liketic commented on issue #3338: Remove global zookeeper option in code base URL: https://github.com/apache/pulsar/pull/3338#issuecomment-453716065 rerun java8 tests This is an automated message from the Apache Git Service.

[GitHub] liketic commented on issue #3307: Remove global-zookeeper in documentation

2019-01-11 Thread GitBox
liketic commented on issue #3307: Remove global-zookeeper in documentation URL: https://github.com/apache/pulsar/pull/3307#issuecomment-453715350 @sijie I updated this PR for removing from documentation, could you please review again? Thanks in advance.

[GitHub] merlimat closed pull request #3360: Support TLS authentication and authorization in standalone mode

2019-01-11 Thread GitBox
merlimat closed pull request #3360: Support TLS authentication and authorization in standalone mode URL: https://github.com/apache/pulsar/pull/3360 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:

[pulsar] branch master updated: Support TLS authentication and authorization in standalone mode (#3360)

2019-01-11 Thread mmerli
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 617712e Support TLS authentication and

[GitHub] merlimat closed pull request #3357: fix dep to make build compatible with jdk11

2019-01-11 Thread GitBox
merlimat closed pull request #3357: fix dep to make build compatible with jdk11 URL: https://github.com/apache/pulsar/pull/3357 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

[pulsar] branch master updated: fix dep to make build compatible with jdk11 (#3357)

2019-01-11 Thread mmerli
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 1484711 fix dep to make build compatible with

[GitHub] lovelle edited a comment on issue #3337: Bug fixes/Improvement for notify pending receive method

2019-01-11 Thread GitBox
lovelle edited a comment on issue #3337: Bug fixes/Improvement for notify pending receive method URL: https://github.com/apache/pulsar/pull/3337#issuecomment-453243731 @sijie @merlimat Could you please review this? This is

[GitHub] srkukarni commented on issue #3363: Enable stats to be recovered by Kubernetes runtime

2019-01-11 Thread GitBox
srkukarni commented on issue #3363: Enable stats to be recovered by Kubernetes runtime URL: https://github.com/apache/pulsar/pull/3363#issuecomment-453694947 rerun java8 tests This is an automated message from the Apache Git

[GitHub] srkukarni opened a new pull request #3363: Enable stats to be recovered by Kubernetes runtime

2019-01-11 Thread GitBox
srkukarni opened a new pull request #3363: Enable stats to be recovered by Kubernetes runtime URL: https://github.com/apache/pulsar/pull/3363 ### Motivation The first implementation of KubernetesRuntime omitted implementing getstats from functions. This pr adds that capability

[GitHub] srkukarni closed pull request #3336: Added HTTP Support

2019-01-11 Thread GitBox
srkukarni closed pull request #3336: Added HTTP Support URL: https://github.com/apache/pulsar/pull/3336 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

[pulsar] branch master updated: Added HTTP Support (#3336)

2019-01-11 Thread sanjeevrk
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 7ec205a Added HTTP Support (#3336) 7ec205a

[GitHub] sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d

2019-01-11 Thread GitBox
sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453661576 remove data and logs directory, create a brand new topic. before starting consumer, server is good. as soon as start

[GitHub] sautran removed a comment on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d

2019-01-11 Thread GitBox
sautran removed a comment on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453655217 i am running local standalone mode. I already removed the data and logs directory, server still kept throwing

[GitHub] srkukarni commented on issue #3324: Add Windowfunction interface to functions api

2019-01-11 Thread GitBox
srkukarni commented on issue #3324: Add Windowfunction interface to functions api URL: https://github.com/apache/pulsar/pull/3324#issuecomment-453655674 rerun integration tests This is an automated message from the Apache

[GitHub] sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d

2019-01-11 Thread GitBox
sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453655217 i am running local standalone mode. I already removed the data and logs directory, server still kept throwing this

[GitHub] srkukarni commented on issue #3338: Remove global zookeeper option in code base

2019-01-11 Thread GitBox
srkukarni commented on issue #3338: Remove global zookeeper option in code base URL: https://github.com/apache/pulsar/pull/3338#issuecomment-453645118 rerun java8 tests This is an automated message from the Apache Git

[GitHub] srkukarni commented on issue #3321: Add doc entry for packaging python dependencies.

2019-01-11 Thread GitBox
srkukarni commented on issue #3321: Add doc entry for packaging python dependencies. URL: https://github.com/apache/pulsar/pull/3321#issuecomment-453643763 rerun integration tests This is an automated message from the Apache

[GitHub] srkukarni commented on a change in pull request #3324: Add Windowfunction interface to functions api

2019-01-11 Thread GitBox
srkukarni commented on a change in pull request #3324: Add Windowfunction interface to functions api URL: https://github.com/apache/pulsar/pull/3324#discussion_r247239113 ## File path: pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/WindowFunction.java

[GitHub] sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d

2019-01-11 Thread GitBox
sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453636095 Consumer log: 20190111.142908.328 INFO [org.apache.kafka.clients.consumer.ConsumerConfig] ConsumerConfig

[GitHub] merlimat commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d

2019-01-11 Thread GitBox
merlimat commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453634289 Ok, that's strange. Can you also include the client logs?

[GitHub] sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d

2019-01-11 Thread GitBox
sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453633946 I set bootstrap.servers pulsar://localhost:6650 in the properties

[GitHub] merlimat commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d

2019-01-11 Thread GitBox
merlimat commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453633054 This seems like it's trying to connect the Pulsar service using HTTP? What service url did you specify?

[GitHub] sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d

2019-01-11 Thread GitBox
sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453631964 Ok. I set the consumer props.put(KafkaKeys.VALUE_DESERIALIZER,

[GitHub] merlimat commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d

2019-01-11 Thread GitBox
merlimat commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453619428 This error is coming from consumer, so it should be the `StringDeserializer` there

[GitHub] sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d

2019-01-11 Thread GitBox
sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453617931 @merlimat , yes, I set the key as StringSerializer props.put("key.serializer",

[GitHub] merlimat commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d

2019-01-11 Thread GitBox
merlimat commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453615985 (Above code was taken from

[GitHub] merlimat commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d

2019-01-11 Thread GitBox
merlimat commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453615684 @sautran The code there should be like : ```java private K getKey(String topic, Message msg) {

[GitHub] rdhabalia commented on issue #3348: Remove broker mode to handle persistent/non-persistent topics separately

2019-01-11 Thread GitBox
rdhabalia commented on issue #3348: Remove broker mode to handle persistent/non-persistent topics separately URL: https://github.com/apache/pulsar/pull/3348#issuecomment-453615210 rerun cpp tests This is an automated message

[GitHub] sautran opened a new issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d

2019-01-11 Thread GitBox
sautran opened a new issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362 I am using kafka api, the topic is persistent and partitioned topic, in the java consumer, the consumer.poll method throws the following

[pulsar] branch master updated: Added filtering to Twitter Firehose Connector (#3298)

2019-01-11 Thread mmerli
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 210d828 Added filtering to Twitter Firehose

[GitHub] merlimat closed pull request #3298: Added filtering to Twitter Firehose Connector

2019-01-11 Thread GitBox
merlimat closed pull request #3298: Added filtering to Twitter Firehose Connector URL: https://github.com/apache/pulsar/pull/3298 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

[pulsar] branch master updated: Fix title and content mismatch issue in cookbooks-partitioned.md (#3349) (#3353)

2019-01-11 Thread mmerli
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 aa20363 Fix title and content mismatch issue

[GitHub] merlimat closed pull request #3353: Fix title and content mismatch issue in cookbooks-partitioned.md (#3349)

2019-01-11 Thread GitBox
merlimat closed pull request #3353: Fix title and content mismatch issue in cookbooks-partitioned.md (#3349) URL: https://github.com/apache/pulsar/pull/3353 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

[GitHub] merlimat closed pull request #3301: Minor typo (cd instead of cp)

2019-01-11 Thread GitBox
merlimat closed pull request #3301: Minor typo (cd instead of cp) URL: https://github.com/apache/pulsar/pull/3301 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

[pulsar] branch master updated (aa20363 -> b14aca8)

2019-01-11 Thread mmerli
This is an automated email from the ASF dual-hosted git repository. mmerli pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from aa20363 Fix title and content mismatch issue in cookbooks-partitioned.md (#3349) (#3353) add b14aca8 Minor

[pulsar] branch master updated: Integration test and documentation for Proxy w/o ZK (#3352)

2019-01-11 Thread mmerli
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 aa3fd10 Integration test and documentation for

[GitHub] merlimat closed pull request #3352: Integration test and documentation for Proxy w/o ZK

2019-01-11 Thread GitBox
merlimat closed pull request #3352: Integration test and documentation for Proxy w/o ZK URL: https://github.com/apache/pulsar/pull/3352 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

[GitHub] merlimat commented on issue #3357: fix dep to make build compatible with jdk11

2019-01-11 Thread GitBox
merlimat commented on issue #3357: fix dep to make build compatible with jdk11 URL: https://github.com/apache/pulsar/pull/3357#issuecomment-453611773 run java8 tests This is an automated message from the Apache Git Service.

[GitHub] merlimat commented on issue #3358: Fix bug consumer stop consume(issue-3131)

2019-01-11 Thread GitBox
merlimat commented on issue #3358: Fix bug consumer stop consume(issue-3131) URL: https://github.com/apache/pulsar/pull/3358#issuecomment-453611577 @codelipenghui The change LGTM. Is it possible to reproduce the issue within a unit test? That would be great to have a better understanding

[GitHub] sautran commented on issue #3361: Kafka configure properties are not included subscription type and subscription mode

2019-01-11 Thread GitBox
sautran commented on issue #3361: Kafka configure properties are not included subscription type and subscription mode URL: https://github.com/apache/pulsar/issues/3361#issuecomment-453611424 @merlimat Great! Thanks. This is

[pulsar] branch master updated: Pass schema info to C++ client (#3354)

2019-01-11 Thread mmerli
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 ef94cb7 Pass schema info to C++ client (#3354)

[GitHub] merlimat closed pull request #3354: Pass schema info to C++ client

2019-01-11 Thread GitBox
merlimat closed pull request #3354: Pass schema info to C++ client URL: https://github.com/apache/pulsar/pull/3354 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

[GitHub] merlimat commented on issue #3361: Kafka configure properties are not included subscription type and subscription mode

2019-01-11 Thread GitBox
merlimat commented on issue #3361: Kafka configure properties are not included subscription type and subscription mode URL: https://github.com/apache/pulsar/issues/3361#issuecomment-453610968 @sautran That's correct. A "failover" subscription over a partitioned topic will work in a

[GitHub] sautran commented on issue #3361: Kafka configure properties are not included subscription type and subscription mode

2019-01-11 Thread GitBox
sautran commented on issue #3361: Kafka configure properties are not included subscription type and subscription mode URL: https://github.com/apache/pulsar/issues/3361#issuecomment-453590038 For the subscriptionType, right now our kafka application have a few consumers using the same

[GitHub] sautran opened a new issue #3361: Kafka configure properties are not included subscription type and subscription mode

2019-01-11 Thread GitBox
sautran opened a new issue #3361: Kafka configure properties are not included subscription type and subscription mode URL: https://github.com/apache/pulsar/issues/3361 I am trying to use the latest pulsar release to migrate current kafka client to pulsar and try to use the kafka pulsar

[GitHub] thatcort commented on issue #1070: Provide a nodejs client

2019-01-11 Thread GitBox
thatcort commented on issue #1070: Provide a nodejs client URL: https://github.com/apache/pulsar/issues/1070#issuecomment-453548857 Just a suggestion to use TypeScript, rather than JavaScript. This is an automated message

[GitHub] ambition119 edited a comment on issue #3294: [IO] [Kafka] a Kafka source submitted with invalid configuration stucks without consuming from Kafka topics

2019-01-11 Thread GitBox
ambition119 edited a comment on issue #3294: [IO] [Kafka] a Kafka source submitted with invalid configuration stucks without consuming from Kafka topics URL: https://github.com/apache/pulsar/issues/3294#issuecomment-453418838 @sijie Use 'source create' command we validate the parameter

[GitHub] tuteng opened a new pull request #3360: Support TLS authentication and authorization in standalone mode

2019-01-11 Thread GitBox
tuteng opened a new pull request #3360: Support TLS authentication and authorization in standalone mode URL: https://github.com/apache/pulsar/pull/3360 ### Motivation I found that in standalone mode, opening TLS authentication would be overwritten.Opening TLS authentication and

[GitHub] ambition119 edited a comment on issue #3294: [IO] [Kafka] a Kafka source submitted with invalid configuration stucks without consuming from Kafka topics

2019-01-11 Thread GitBox
ambition119 edited a comment on issue #3294: [IO] [Kafka] a Kafka source submitted with invalid configuration stucks without consuming from Kafka topics URL: https://github.com/apache/pulsar/issues/3294#issuecomment-453418838 @merlimat @sijie Use 'source create' command we validate the

[GitHub] ambition119 edited a comment on issue #3294: [IO] [Kafka] a Kafka source submitted with invalid configuration stucks without consuming from Kafka topics

2019-01-11 Thread GitBox
ambition119 edited a comment on issue #3294: [IO] [Kafka] a Kafka source submitted with invalid configuration stucks without consuming from Kafka topics URL: https://github.com/apache/pulsar/issues/3294#issuecomment-453418838 Use 'source create' command we validate the parameter key is

[GitHub] ambition119 edited a comment on issue #3294: [IO] [Kafka] a Kafka source submitted with invalid configuration stucks without consuming from Kafka topics

2019-01-11 Thread GitBox
ambition119 edited a comment on issue #3294: [IO] [Kafka] a Kafka source submitted with invalid configuration stucks without consuming from Kafka topics URL: https://github.com/apache/pulsar/issues/3294#issuecomment-453418838 Use 'source create' command we validate the parameter key is

[GitHub] ambition119 commented on issue #3294: [IO] [Kafka] a Kafka source submitted with invalid configuration stucks without consuming from Kafka topics

2019-01-11 Thread GitBox
ambition119 commented on issue #3294: [IO] [Kafka] a Kafka source submitted with invalid configuration stucks without consuming from Kafka topics URL: https://github.com/apache/pulsar/issues/3294#issuecomment-453418838 Use 'source create' command we validate verify that the parameter key

[GitHub] ambition119 edited a comment on issue #3294: [IO] [Kafka] a Kafka source submitted with invalid configuration stucks without consuming from Kafka topics

2019-01-11 Thread GitBox
ambition119 edited a comment on issue #3294: [IO] [Kafka] a Kafka source submitted with invalid configuration stucks without consuming from Kafka topics URL: https://github.com/apache/pulsar/issues/3294#issuecomment-453418838 Use 'source create' command we validate the parameter key is

[GitHub] JesusIslam commented on issue #3359: Failed to build Golang client.

2019-01-11 Thread GitBox
JesusIslam commented on issue #3359: Failed to build Golang client. URL: https://github.com/apache/pulsar/issues/3359#issuecomment-453418589 Turned out I missed this explanation in [this page.](https://pulsar.apache.org/docs/latest/clients/go/)

[GitHub] JesusIslam edited a comment on issue #3359: Failed to build Golang client.

2019-01-11 Thread GitBox
JesusIslam edited a comment on issue #3359: Failed to build Golang client. URL: https://github.com/apache/pulsar/issues/3359#issuecomment-453418589 Turned out I missed this explanation in [this page.](https://pulsar.apache.org/docs/latest/clients/go/) > Pulsar Go client library is

[GitHub] JesusIslam closed issue #3359: Failed to build Golang client.

2019-01-11 Thread GitBox
JesusIslam closed issue #3359: Failed to build Golang client. URL: https://github.com/apache/pulsar/issues/3359 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and