[GitHub] codelipenghui commented on issue #2688: Polices On Topic

codelipenghui commented on issue #2688: Polices On Topic URL: https://github.com/apache/pulsar/issues/2688#issuecomment-432108404 @ivankelly > > This change will cause more load on zookeeper. For each topic loaded, we would have to do a read for the policy of that topic when loading

[GitHub] merlimat closed pull request #2819: Add a simple log4j configuration for PrometheusMetricsServer

merlimat closed pull request #2819: Add a simple log4j configuration for PrometheusMetricsServer URL: https://github.com/apache/pulsar/pull/2819 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

[GitHub] merlimat commented on issue #2815: Add http output buffer configuration to proxy

merlimat commented on issue #2815: Add http output buffer configuration to proxy URL: https://github.com/apache/pulsar/pull/2815#issuecomment-432103750 run cpp tests This is an automated message from the Apache Git Service. To

[pulsar] branch master updated: Add a simple log4j configuration for PrometheusMetricsServer (#2819)

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 f0a81cb Add a simple log4j configuration for Pr

[pulsar] branch master updated: Specify default for cpu/ram/disk (#2820)

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 c7c7696 Specify default for cpu/ram/disk (#2820

[GitHub] merlimat closed pull request #2820: Specify default for cpu/ram/disk

merlimat closed pull request #2820: Specify default for cpu/ram/disk URL: https://github.com/apache/pulsar/pull/2820 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 reques

[GitHub] codelipenghui commented on issue #2375: Support for delayed message delivery

codelipenghui commented on issue #2375: Support for delayed message delivery URL: https://github.com/apache/pulsar/issues/2375#issuecomment-432100521 @pmwqld > We would like to use such a feature to implement an AUTO Dead Letter Queue (DLQ). Any messages that cannot be processed fro

[GitHub] pmwqld commented on issue #2375: Support for delayed message delivery

pmwqld commented on issue #2375: Support for delayed message delivery URL: https://github.com/apache/pulsar/issues/2375#issuecomment-432097273 We would like to use such a feature to implement an AUTO Dead Letter Queue (DLQ). Any messages that cannot be processed from the main topic can be s

[GitHub] Lizhooh opened a new issue #2821: [Request] Pulsar client libraries Support Nodejs

Lizhooh opened a new issue #2821: [Request] Pulsar client libraries Support Nodejs URL: https://github.com/apache/pulsar/issues/2821 [Request] Pulsar client libraries Support Nodejs This is an automated message from the Apach

[GitHub] hrsakai commented on issue #2814: Fix memory issue in cpp ZTSClient

hrsakai commented on issue #2814: Fix memory issue in cpp ZTSClient URL: https://github.com/apache/pulsar/pull/2814#issuecomment-432075828 retest this please This is an automated message from the Apache Git Service. To respond

[GitHub] srkukarni commented on issue #2820: Specify default for cpu/ram/disk

srkukarni commented on issue #2820: Specify default for cpu/ram/disk URL: https://github.com/apache/pulsar/pull/2820#issuecomment-432074450 rerun java8 tests This is an automated message from the Apache Git Service. To respond

[GitHub] nkurihar commented on issue #2749: Admin API via PulsarProxy with authentication fails

nkurihar commented on issue #2749: Admin API via PulsarProxy with authentication fails URL: https://github.com/apache/pulsar/issues/2749#issuecomment-432072845 In my opinion, regardless of auth methods(TLS, Athenz, etc.), authentication/authorization of original client in broker side is no

[GitHub] hrsakai commented on a change in pull request #2814: Fix memory issue in cpp ZTSClient

hrsakai commented on a change in pull request #2814: Fix memory issue in cpp ZTSClient URL: https://github.com/apache/pulsar/pull/2814#discussion_r227203601 ## File path: pulsar-client-cpp/lib/auth/athenz/ZTSClient.cc ## @@ -143,7 +143,7 @@ std::string ZTSClient::ybase64En

[GitHub] srkukarni commented on issue #2820: Specify default for cpu/ram/disk

srkukarni commented on issue #2820: Specify default for cpu/ram/disk URL: https://github.com/apache/pulsar/pull/2820#issuecomment-432064867 rerun integration tests This is an automated message from the Apache Git Service. To r

[GitHub] srkukarni commented on issue #2818: Moved FunctionConfig/SourceConfig/SinkConfig to a more common location

srkukarni commented on issue #2818: Moved FunctionConfig/SourceConfig/SinkConfig to a more common location URL: https://github.com/apache/pulsar/pull/2818#issuecomment-432064573 rerun integration tests This is an automated me

[GitHub] srkukarni commented on issue #2818: Moved FunctionConfig/SourceConfig/SinkConfig to a more common location

srkukarni commented on issue #2818: Moved FunctionConfig/SourceConfig/SinkConfig to a more common location URL: https://github.com/apache/pulsar/pull/2818#issuecomment-432055564 rerun integration tests This is an automated me

[GitHub] srkukarni commented on issue #2819: Add a simple log4j configuration for PrometheusMetricsServer

srkukarni commented on issue #2819: Add a simple log4j configuration for PrometheusMetricsServer URL: https://github.com/apache/pulsar/pull/2819#issuecomment-432049838 rerun java8 tests This is an automated message from the A

[GitHub] srkukarni commented on issue #2819: Add a simple log4j configuration for PrometheusMetricsServer

srkukarni commented on issue #2819: Add a simple log4j configuration for PrometheusMetricsServer URL: https://github.com/apache/pulsar/pull/2819#issuecomment-432049810 rerun integration tests This is an automated message from

[GitHub] srkukarni commented on issue #2818: Moved FunctionConfig/SourceConfig/SinkConfig to a more common location

srkukarni commented on issue #2818: Moved FunctionConfig/SourceConfig/SinkConfig to a more common location URL: https://github.com/apache/pulsar/pull/2818#issuecomment-432037116 rerun integration tests This is an automated me

[pulsar] branch master updated: Logs should be output to stdout when running functions in Kubernetes (#2817)

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 75d9fe2 Logs should be output to stdout when

[GitHub] srkukarni closed pull request #2817: Logs should be output to stdout when running functions in Kubernetes

srkukarni closed pull request #2817: Logs should be output to stdout when running functions in Kubernetes URL: https://github.com/apache/pulsar/pull/2817 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 provena

[GitHub] srkukarni opened a new pull request #2820: Specify default for cpu/ram/disk

srkukarni opened a new pull request #2820: Specify default for cpu/ram/disk URL: https://github.com/apache/pulsar/pull/2820 ### Motivation Explain here the context, and why you're making that change. What is the problem you're trying to solve. ### Modifications Descri

[GitHub] srkukarni commented on issue #2818: Moved FunctionConfig/SourceConfig/SinkConfig to a more common location

srkukarni commented on issue #2818: Moved FunctionConfig/SourceConfig/SinkConfig to a more common location URL: https://github.com/apache/pulsar/pull/2818#issuecomment-432025246 rerun integration tests This is an automated me

[GitHub] srkukarni opened a new pull request #2819: Add a simple log4j configuration for PrometheusMetricsServer

srkukarni opened a new pull request #2819: Add a simple log4j configuration for PrometheusMetricsServer URL: https://github.com/apache/pulsar/pull/2819 ### Motivation Explain here the context, and why you're making that change. What is the problem you're trying to solve. ##

[GitHub] srkukarni opened a new pull request #2818: Moved FunctionConfig/SourceConfig/SinkConfig to a more common location

srkukarni opened a new pull request #2818: Moved FunctionConfig/SourceConfig/SinkConfig to a more common location URL: https://github.com/apache/pulsar/pull/2818 ### Motivation As part of the goal to remove function dependency on pulsar-admin, this pr moves Config related stuff to a

[GitHub] jerrypeng commented on a change in pull request #2817: Logs should be output to stdout when running functions in Kubernetes

jerrypeng commented on a change in pull request #2817: Logs should be output to stdout when running functions in Kubernetes URL: https://github.com/apache/pulsar/pull/2817#discussion_r227107382 ## File path: pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime

[GitHub] srkukarni commented on a change in pull request #2817: Logs should be output to stdout when running functions in Kubernetes

srkukarni commented on a change in pull request #2817: Logs should be output to stdout when running functions in Kubernetes URL: https://github.com/apache/pulsar/pull/2817#discussion_r227106898 ## File path: pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime

[GitHub] jerrypeng opened a new pull request #2817: Logs should be output to stdout when running functions in Kubernetes

jerrypeng opened a new pull request #2817: Logs should be output to stdout when running functions in Kubernetes URL: https://github.com/apache/pulsar/pull/2817 ### Motivation Currently when running functions in kubernetes, logs are written to logs within the container which forces u

[GitHub] ivankelly commented on issue #2815: Add http output buffer configuration to proxy

ivankelly commented on issue #2815: Add http output buffer configuration to proxy URL: https://github.com/apache/pulsar/pull/2815#issuecomment-431930887 retest this please This is an automated message from the Apache Git Serv

[pulsar] branch master updated (b73a967 -> 32d1daf)

This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from b73a967 Bump jetty to v9.4.12 (#2811) add 32d1daf Removed Validation Annotations and do manual Validation

[GitHub] srkukarni commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

srkukarni commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r227069195 ## File path: pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/windowing/WindowFun

[GitHub] jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r227068396 ## File path: pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/windowing/WindowFun

[GitHub] jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r227067103 ## File path: pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/windowing/WindowFun

[GitHub] srkukarni commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

srkukarni commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r227066421 ## File path: pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/windowing/WindowFun

[GitHub] srkukarni commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

srkukarni commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r227065908 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowFun

[GitHub] jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r227063452 ## File path: pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/windowing/WindowFun

[GitHub] jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r227063452 ## File path: pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/windowing/WindowFun

[GitHub] jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r227062797 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowFun

[GitHub] jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r226881791 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowFun

[GitHub] jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r226883130 ## File path: pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfig.j

[GitHub] jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r226881738 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowFun

[GitHub] jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r226883075 ## File path: pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfig.j

[GitHub] jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r226881801 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowFun

[GitHub] jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r226883163 ## File path: pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarFunctionTlsTest.java ##

[GitHub] jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r226882232 ## File path: pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarFunctionTlsTest.java ##

[GitHub] jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r226883146 ## File path: pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarFunctionTlsTest.java ##

[GitHub] jerrypeng removed a comment on issue #2813: Removed Validation Annotations and do manual Validation

jerrypeng removed a comment on issue #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#issuecomment-431711713 dsfs This is an automated message from the Apache Git

[GitHub] jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r226882049 ## File path: pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/Utils.java

[GitHub] jerrypeng removed a comment on issue #2813: Removed Validation Annotations and do manual Validation

jerrypeng removed a comment on issue #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#issuecomment-431711824 dsfsdfd This is an automated message from the Apache G

[GitHub] jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

jerrypeng commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r226882040 ## File path: pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/Utils.java

[GitHub] merlimat commented on issue #2816: pulsar-admin unable to peek messages from a subscription when a '/' is in subscription name

merlimat commented on issue #2816: pulsar-admin unable to peek messages from a subscription when a '/' is in subscription name URL: https://github.com/apache/pulsar/issues/2816#issuecomment-431886766 This is being addressed in #2809

[GitHub] cckellogg opened a new issue #2816: pulsar-admin unable to peek messages from a subscription when a '/' is in subscription name

cckellogg opened a new issue #2816: pulsar-admin unable to peek messages from a subscription when a '/' is in subscription name URL: https://github.com/apache/pulsar/issues/2816 The pulsar-admin is not able to peek message from a subscription when a '/' is in the subscription name.

[GitHub] ivankelly commented on issue #2815: Add http output buffer configuration to proxy

ivankelly commented on issue #2815: Add http output buffer configuration to proxy URL: https://github.com/apache/pulsar/pull/2815#issuecomment-431880143 @cckellogg This is an automated message from the Apache Git Service. To

[GitHub] srkukarni commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

srkukarni commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r226995692 ## File path: pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/windowing/WindowFun

[GitHub] srkukarni commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation

srkukarni commented on a change in pull request #2813: Removed Validation Annotations and do manual Validation URL: https://github.com/apache/pulsar/pull/2813#discussion_r226995410 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowFun

[GitHub] ivankelly opened a new pull request #2815: Add http output buffer configuration to proxy

ivankelly opened a new pull request #2815: Add http output buffer configuration to proxy URL: https://github.com/apache/pulsar/pull/2815 This controls the amount of data the http proxy will buffer before flushing to the client. Setting this to something very low facilitates streaming

[GitHub] sijie commented on issue #2791: Debezium: integrate KafkaConnectSource with MySqlConnectorTask

sijie commented on issue #2791: Debezium: integrate KafkaConnectSource with MySqlConnectorTask URL: https://github.com/apache/pulsar/pull/2791#issuecomment-431823531 @jiazhai you can consider making a new test case just for debezium related tests. -

[GitHub] maskit commented on a change in pull request #2814: Fix memory issue in cpp ZTSClient

maskit commented on a change in pull request #2814: Fix memory issue in cpp ZTSClient URL: https://github.com/apache/pulsar/pull/2814#discussion_r226946724 ## File path: pulsar-client-cpp/lib/auth/athenz/ZTSClient.cc ## @@ -143,7 +143,7 @@ std::string ZTSClient::ybase64Enc

[GitHub] maskit commented on a change in pull request #2814: Fix memory issue in cpp ZTSClient

maskit commented on a change in pull request #2814: Fix memory issue in cpp ZTSClient URL: https://github.com/apache/pulsar/pull/2814#discussion_r226946772 ## File path: pulsar-client-cpp/lib/auth/athenz/ZTSClient.cc ## @@ -143,7 +143,7 @@ std::string ZTSClient::ybase64Enc

[GitHub] maskit commented on a change in pull request #2814: Fix memory issue in cpp ZTSClient

maskit commented on a change in pull request #2814: Fix memory issue in cpp ZTSClient URL: https://github.com/apache/pulsar/pull/2814#discussion_r226947435 ## File path: pulsar-client-cpp/lib/auth/athenz/ZTSClient.cc ## @@ -143,7 +143,7 @@ std::string ZTSClient::ybase64Enc

[GitHub] maskit commented on a change in pull request #2814: Fix memory issue in cpp ZTSClient

maskit commented on a change in pull request #2814: Fix memory issue in cpp ZTSClient URL: https://github.com/apache/pulsar/pull/2814#discussion_r226946662 ## File path: pulsar-client-cpp/lib/auth/athenz/ZTSClient.cc ## @@ -143,7 +143,7 @@ std::string ZTSClient::ybase64Enc

[GitHub] maskit commented on a change in pull request #2814: Fix memory issue in cpp ZTSClient

maskit commented on a change in pull request #2814: Fix memory issue in cpp ZTSClient URL: https://github.com/apache/pulsar/pull/2814#discussion_r226946881 ## File path: pulsar-client-cpp/lib/auth/athenz/ZTSClient.cc ## @@ -143,7 +143,7 @@ std::string ZTSClient::ybase64Enc

[pulsar] branch master updated (f3a027b -> b73a967)

This is an automated email from the ASF dual-hosted git repository. ivank pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from f3a027b Added stop/restart functionality in sources/sinks (#2810) add b73a967 Bump jetty to v9.4.12 (#2811) No

[GitHub] ivankelly closed pull request #2811: Bump jetty to v9.4.12

ivankelly closed pull request #2811: Bump jetty to v9.4.12 URL: https://github.com/apache/pulsar/pull/2811 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