Last active
July 15, 2021 08:13
-
-
Save nha/34ad0c14cbf22ef282d452d45712ec32 to your computer and use it in GitHub Desktop.
pulsar_proxy_local
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| #error { | |
| :cause Connection refused | |
| :via | |
| [{:type org.apache.pulsar.client.api.PulsarClientException | |
| :message java.util.concurrent.ExecutionException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: /127.0.0.1:6660 | |
| :at [org.apache.pulsar.client.api.PulsarClientException unwrap PulsarClientException.java 1027]} | |
| {:type java.util.concurrent.ExecutionException | |
| :message org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: /127.0.0.1:6660 | |
| :at [java.util.concurrent.CompletableFuture reportGet CompletableFuture.java 395]} | |
| {:type org.apache.pulsar.client.api.PulsarClientException | |
| :message java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: /127.0.0.1:6660 | |
| :at [org.apache.pulsar.client.impl.ConnectionPool lambda$createConnection$9 ConnectionPool.java 216]} | |
| {:type java.util.concurrent.CompletionException | |
| :message io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: /127.0.0.1:6660 | |
| :at [java.util.concurrent.CompletableFuture encodeThrowable CompletableFuture.java 331]} | |
| {:type io.netty.channel.AbstractChannel$AnnotatedConnectException | |
| :message Connection refused: /127.0.0.1:6660} | |
| {:type java.net.ConnectException | |
| :message Connection refused | |
| :at [sun.nio.ch.SocketChannelImpl checkConnect SocketChannelImpl.java -2]}] | |
| :trace | |
| [[sun.nio.ch.SocketChannelImpl checkConnect SocketChannelImpl.java -2] | |
| [sun.nio.ch.SocketChannelImpl finishConnect SocketChannelImpl.java 779] | |
| [io.netty.channel.socket.nio.NioSocketChannel doFinishConnect NioSocketChannel.java 330] | |
| [io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe finishConnect AbstractNioChannel.java 334] | |
| [io.netty.channel.nio.NioEventLoop processSelectedKey NioEventLoop.java 702] | |
| [io.netty.channel.nio.NioEventLoop processSelectedKeysOptimized NioEventLoop.java 650] | |
| [io.netty.channel.nio.NioEventLoop processSelectedKeys NioEventLoop.java 576] | |
| [io.netty.channel.nio.NioEventLoop run NioEventLoop.java 493] | |
| [io.netty.util.concurrent.SingleThreadEventExecutor$4 run SingleThreadEventExecutor.java 989] | |
| [io.netty.util.internal.ThreadExecutorMap$2 run ThreadExecutorMap.java 74] | |
| [io.netty.util.concurrent.FastThreadLocalRunnable run FastThreadLocalRunnable.java 30] | |
| [java.lang.Thread run Thread.java 834]]} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| image: apachepulsar/pulsar:2.8.0 | |
| ports: | |
| - "8190:80" # ? | |
| - "8080:8080" | |
| - "8081:8081" | |
| - "6650:6650" # I am able to access this via the java client pointing to "pulsar://127.0.0.1:6650" | |
| - "2181:2181" | |
| command: > | |
| /bin/bash -c | |
| "bin/apply-config-from-env.py conf/standalone.conf | |
| && bin/pulsar standalone" |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| # | |
| # Licensed to the Apache Software Foundation (ASF) under one | |
| # or more contributor license agreements. See the NOTICE file | |
| # distributed with this work for additional information | |
| # regarding copyright ownership. The ASF licenses this file | |
| # to you under the Apache License, Version 2.0 (the | |
| # "License"); you may not use this file except in compliance | |
| # with the License. You may obtain a copy of the License at | |
| # | |
| # http://www.apache.org/licenses/LICENSE-2.0 | |
| # | |
| # Unless required by applicable law or agreed to in writing, | |
| # software distributed under the License is distributed on an | |
| # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY | |
| # KIND, either express or implied. See the License for the | |
| # specific language governing permissions and limitations | |
| # under the License. | |
| # | |
| ### --- Broker Discovery --- ### | |
| # The ZooKeeper quorum connection string (as a comma-separated list) | |
| zookeeperServers=127.0.0.1 | |
| # Configuration store connection string (as a comma-separated list) | |
| configurationStoreServers=127.0.0.1:2181 | |
| # if Service Discovery is Disabled this url should point to the discovery service provider. | |
| brokerServiceURL=pulsar://127.0.0.1:6650 | |
| brokerServiceURLTLS= | |
| # These settings are unnecessary if `zookeeperServers` is specified | |
| brokerWebServiceURL=http://127.0.0.1:8080 | |
| brokerWebServiceURLTLS= | |
| # If function workers are setup in a separate cluster, configure the following 2 settings | |
| # to point to the function workers cluster | |
| functionWorkerWebServiceURL=http://127.0.0.1:8080 | |
| functionWorkerWebServiceURLTLS= | |
| # ZooKeeper session timeout (in milliseconds) | |
| zookeeperSessionTimeoutMs=30000 | |
| # ZooKeeper cache expiry time in seconds | |
| zooKeeperCacheExpirySeconds=300 | |
| ### --- Server --- ### | |
| # Hostname or IP address the service binds on, default is 0.0.0.0. | |
| bindAddress=0.0.0.0 | |
| # Hostname or IP address the service advertises to the outside world. | |
| # If not set, the value of `InetAddress.getLocalHost().getHostname()` is used. | |
| advertisedAddress= | |
| # Enable or disable the HAProxy protocol. | |
| haProxyProtocolEnabled=false | |
| # The port to use for server binary Protobuf requests | |
| servicePort=6660 | |
| # The port to use to server binary Protobuf TLS requests | |
| servicePortTls= | |
| # Port that discovery service listen on | |
| webServicePort=8082 | |
| # Port to use to server HTTPS request | |
| webServicePortTls= | |
| # Path for the file used to determine the rotation status for the proxy instance when responding | |
| # to service discovery health checks | |
| statusFilePath= | |
| # Proxy log level, default is 0. | |
| # 0: Do not log any tcp channel info | |
| # 1: Parse and log any tcp channel info and command info without message body | |
| # 2: Parse and log channel info, command info and message body | |
| proxyLogLevel=2 | |
| ### ---Authorization --- ### | |
| # Role names that are treated as "super-users," meaning that they will be able to perform all admin | |
| # operations and publish/consume to/from all topics (as a comma-separated list) | |
| superUserRoles= | |
| # Whether authorization is enforced by the Pulsar proxy | |
| authorizationEnabled=false | |
| # Authorization provider as a fully qualified class name | |
| authorizationProvider=org.apache.pulsar.broker.authorization.PulsarAuthorizationProvider | |
| # Whether client authorization credentials are forwared to the broker for re-authorization. | |
| # Authentication must be enabled via authenticationEnabled=true for this to take effect. | |
| forwardAuthorizationCredentials=false | |
| ### --- Authentication --- ### | |
| # Whether authentication is enabled for the Pulsar proxy | |
| authenticationEnabled=false | |
| # Authentication provider name list (a comma-separated list of class names) | |
| authenticationProviders= | |
| # When this parameter is not empty, unauthenticated users perform as anonymousUserRole | |
| anonymousUserRole= | |
| ### --- Client Authentication --- ### | |
| # The three brokerClient* authentication settings below are for the proxy itself and determine how it | |
| # authenticates with Pulsar brokers | |
| # The authentication plugin used by the Pulsar proxy to authenticate with Pulsar brokers | |
| brokerClientAuthenticationPlugin= | |
| # The authentication parameters used by the Pulsar proxy to authenticate with Pulsar brokers | |
| brokerClientAuthenticationParameters= | |
| # The path to trusted certificates used by the Pulsar proxy to authenticate with Pulsar brokers | |
| brokerClientTrustCertsFilePath= | |
| # Whether TLS is enabled when communicating with Pulsar brokers | |
| tlsEnabledWithBroker=false | |
| # Tls cert refresh duration in seconds (set 0 to check on every new connection) | |
| tlsCertRefreshCheckDurationSec=300 | |
| ##### --- Rate Limiting --- ##### | |
| # Max concurrent inbound connections. The proxy will reject requests beyond that. | |
| maxConcurrentInboundConnections=100 | |
| # Max concurrent outbound connections. The proxy will error out requests beyond that. | |
| maxConcurrentLookupRequests=500 | |
| ##### --- TLS --- ##### | |
| # Deprecated - use servicePortTls and webServicePortTls instead | |
| tlsEnabledInProxy=false | |
| # Path for the TLS certificate file | |
| tlsCertificateFilePath= | |
| # Path for the TLS private key file | |
| tlsKeyFilePath= | |
| # Path for the trusted TLS certificate file. | |
| # This cert is used to verify that any certs presented by connecting clients | |
| # are signed by a certificate authority. If this verification | |
| # fails, then the certs are untrusted and the connections are dropped. | |
| tlsTrustCertsFilePath= | |
| # Accept untrusted TLS certificate from client. | |
| # If true, a client with a cert which cannot be verified with the | |
| # 'tlsTrustCertsFilePath' cert will allowed to connect to the server, | |
| # though the cert will not be used for client authentication. | |
| tlsAllowInsecureConnection=true | |
| # Whether the hostname is validated when the proxy creates a TLS connection with brokers | |
| tlsHostnameVerificationEnabled=false | |
| # Specify the tls protocols the broker will use to negotiate during TLS handshake | |
| # (a comma-separated list of protocol names). | |
| # Examples:- [TLSv1.3, TLSv1.2] | |
| tlsProtocols= | |
| # Specify the tls cipher the broker will use to negotiate during TLS Handshake | |
| # (a comma-separated list of ciphers). | |
| # Examples:- [TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256] | |
| tlsCiphers= | |
| # Whether client certificates are required for TLS. Connections are rejected if the client | |
| # certificate isn't trusted. | |
| tlsRequireTrustedClientCertOnConnect=false | |
| ##### --- HTTP --- ##### | |
| # Http directs to redirect to non-pulsar services. | |
| httpReverseProxyConfigs= | |
| # Http output buffer size. The amount of data that will be buffered for http requests | |
| # before it is flushed to the channel. A larger buffer size may result in higher http throughput | |
| # though it may take longer for the client to see data. | |
| # If using HTTP streaming via the reverse proxy, this should be set to the minimum value, 1, | |
| # so that clients see the data as soon as possible. | |
| httpOutputBufferSize=32768 | |
| # Number of threads to use for HTTP requests processing. Default is | |
| # 2 * Runtime.getRuntime().availableProcessors() | |
| httpNumThreads= | |
| # Enable the enforcement of limits on the incoming HTTP requests | |
| httpRequestsLimitEnabled=false | |
| # Max HTTP requests per seconds allowed. The excess of requests will be rejected with HTTP code 429 (Too many requests) | |
| httpRequestsMaxPerSecond=100.0 | |
| ### --- Token Authentication Provider --- ### | |
| ## Symmetric key | |
| # Configure the secret key to be used to validate auth tokens | |
| # The key can be specified like: | |
| # tokenSecretKey=data:;base64,xxxxxxxxx | |
| # tokenSecretKey=file:///my/secret.key ( Note: key file must be DER-encoded ) | |
| tokenSecretKey= | |
| ## Asymmetric public/private key pair | |
| # Configure the public key to be used to validate auth tokens | |
| # The key can be specified like: | |
| # tokenPublicKey=data:;base64,xxxxxxxxx | |
| # tokenPublicKey=file:///my/public.key ( Note: key file must be DER-encoded ) | |
| tokenPublicKey= | |
| # The token "claim" that will be interpreted as the authentication "role" or "principal" by AuthenticationProviderToken (defaults to "sub" if blank) | |
| tokenAuthClaim= | |
| # The token audience "claim" name, e.g. "aud", that will be used to get the audience from token. | |
| # If not set, audience will not be verified. | |
| tokenAudienceClaim= | |
| # The token audience stands for this broker. The field `tokenAudienceClaim` of a valid token, need contains this. | |
| tokenAudience= | |
| ### --- WebSocket config variables --- ### | |
| # Enable or disable the WebSocket servlet. | |
| webSocketServiceEnabled=false | |
| # Name of the cluster to which this broker belongs to | |
| clusterName=pulsarstandalone | |
| ### --- Deprecated config variables --- ### | |
| # Deprecated. Use configurationStoreServers | |
| globalZookeeperServers= |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| bin/pulsar proxy | |
| 09:01:55.850 [main] INFO org.apache.pulsar.broker.authentication.AuthenticationService - Authentication is disabled | |
| 09:01:55.976 [main] INFO org.eclipse.jetty.util.log - Logging initialized @2165ms to org.eclipse.jetty.util.log.Slf4jLog | |
| 09:01:56.098 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:zookeeper.version=3.6.3--6401e4ad2087061bc6b9f80dec2d69f2e3c8660a, built on 04/08/2021 16:35 GMT | |
| 09:01:56.098 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:host.name=192.168.1.38 | |
| 09:01:56.098 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.version=11.0.10 | |
| 09:01:56.099 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.vendor=GraalVM Community | |
| 09:01:56.099 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.home=/Users/nha/.jabba/jdk/graalvm-ce-java11@21.0.0/Contents/Home | |
| 09:01:56.099 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.class.path=/Users/nha/repo/pulsar/conf:/Users/nha/repo/pulsar/pulsar-broker/target/pulsar-functions-api-examples.jar:.:/Users/nha/.classpath/antlr-4.7.1-complete.jar::/Users/nha/repo/pulsar/pulsar-broker/target/pulsar-broker.jar:/Users/nha/.m2/repository/commons-codec/commons-codec/1.10/commons-codec-1.10.jar:/Users/nha/.m2/repository/commons-collections/commons-collections/3.2.2/commons-collections-3.2.2.jar:/Users/nha/.m2/repository/org/apache/commons/commons-lang3/3.11/commons-lang3-3.11.jar:/Users/nha/.m2/repository/org/slf4j/slf4j-api/1.7.25/slf4j-api-1.7.25.jar:/Users/nha/.m2/repository/io/netty/netty-transport/4.1.63.Final/netty-transport-4.1.63.Final.jar:/Users/nha/.m2/repository/com/google/protobuf/protobuf-java/3.11.4/protobuf-java-3.11.4.jar:/Users/nha/repo/pulsar/pulsar-client/target/pulsar-client-original.jar:/Users/nha/repo/pulsar/pulsar-client-api/target/pulsar-client-api.jar:/Users/nha/.m2/repository/org/apache/avro/avro-protobuf/1.10.2/avro-protobuf-1.10.2.jar:/Users/nha/.m2/repository/net/jcip/jcip-annotations/1.0/jcip-annotations-1.0.jar:/Users/nha/repo/pulsar/pulsar-websocket/target/pulsar-websocket.jar:/Users/nha/.m2/repository/org/eclipse/jetty/websocket/websocket-api/9.4.42.v20210604/websocket-api-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/eclipse/jetty/websocket/websocket-server/9.4.42.v20210604/websocket-server-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/eclipse/jetty/websocket/websocket-common/9.4.42.v20210604/websocket-common-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/eclipse/jetty/websocket/websocket-client/9.4.42.v20210604/websocket-client-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/eclipse/jetty/websocket/websocket-servlet/9.4.42.v20210604/websocket-servlet-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/eclipse/jetty/websocket/javax-websocket-client-impl/9.4.42.v20210604/javax-websocket-client-impl-9.4.42.v20210604.jar:/Users/nha/.m2/repository/javax/websocket/javax.websocket-client-api/1.0/javax.websocket-client-api-1.0.jar:/Users/nha/repo/pulsar/pulsar-client-admin/target/pulsar-client-admin-original.jar:/Users/nha/repo/pulsar/managed-ledger/target/managed-ledger.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/stats/codahale-metrics-provider/4.14.1/codahale-metrics-provider-4.14.1.jar:/Users/nha/repo/pulsar/pulsar-metadata/target/pulsar-metadata.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/bookkeeper-tools-framework/4.14.1/bookkeeper-tools-framework-4.14.1.jar:/Users/nha/repo/pulsar/pulsar-broker-common/target/pulsar-broker-common.jar:/Users/nha/.m2/repository/javax/servlet/javax.servlet-api/3.1.0/javax.servlet-api-3.1.0.jar:/Users/nha/.m2/repository/io/jsonwebtoken/jjwt-impl/0.11.1/jjwt-impl-0.11.1.jar:/Users/nha/.m2/repository/io/jsonwebtoken/jjwt-api/0.11.1/jjwt-api-0.11.1.jar:/Users/nha/.m2/repository/io/jsonwebtoken/jjwt-jackson/0.11.1/jjwt-jackson-0.11.1.jar:/Users/nha/repo/pulsar/pulsar-transaction/common/target/pulsar-transaction-common.jar:/Users/nha/repo/pulsar/pulsar-zookeeper-utils/target/pulsar-zookeeper-utils.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/stream-storage-server/4.14.1/stream-storage-server-4.14.1.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/stream-storage-service-impl/4.14.1/stream-storage-service-impl-4.14.1.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/stream-storage-service-api/4.14.1/stream-storage-service-api-4.14.1.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/stream-storage-proto/4.14.1/stream-storage-proto-4.14.1.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/stream-storage-java-client-base/4.14.1/stream-storage-java-client-base-4.14.1.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/stream-storage-api/4.14.1/stream-storage-api-4.14.1.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/statelib/4.14.1/statelib-4.14.1.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/stream-storage-common/4.14.1/stream-storage-common-4.14.1.jar:/Users/nha/.m2/repository/org/apache/distributedlog/distributedlog-core/4.14.1/distributedlog-core-4.14.1-tests.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/stream-storage-java-client/4.14.1/stream-storage-java-client-4.14.1.jar:/Users/nha/.m2/repository/io/opencensus/opencensus-api/0.18.0/opencensus-api-0.18.0.jar:/Users/nha/.m2/repository/com/google/auto/value/auto-value-annotations/1.7/auto-value-annotations-1.7.jar:/Users/nha/.m2/repository/com/google/http-client/google-http-client/1.34.0/google-http-client-1.34.0.jar:/Users/nha/.m2/repository/io/opencensus/opencensus-contrib-http-util/0.24.0/opencensus-contrib-http-util-0.24.0.jar:/Users/nha/.m2/repository/com/google/http-client/google-http-client-jackson2/1.34.0/google-http-client-jackson2-1.34.0.jar:/Users/nha/.m2/repository/org/inferred/freebuilder/1.14.9/freebuilder-1.14.9.jar:/Users/nha/.m2/repository/org/apache/curator/curator-recipes/5.1.0/curator-recipes-5.1.0.jar:/Users/nha/.m2/repository/org/apache/curator/curator-framework/5.1.0/curator-framework-5.1.0.jar:/Users/nha/.m2/repository/org/apache/curator/curator-client/5.1.0/curator-client-5.1.0.jar:/Users/nha/.m2/repository/com/github/ben-manes/caffeine/caffeine/2.6.2/caffeine-2.6.2.jar:/Users/nha/.m2/repository/io/prometheus/simpleclient_caffeine/0.5.0/simpleclient_caffeine-0.5.0.jar:/Users/nha/.m2/repository/org/eclipse/jetty/jetty-server/9.4.42.v20210604/jetty-server-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/eclipse/jetty/jetty-http/9.4.42.v20210604/jetty-http-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/eclipse/jetty/jetty-io/9.4.42.v20210604/jetty-io-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/eclipse/jetty/jetty-alpn-conscrypt-server/9.4.42.v20210604/jetty-alpn-conscrypt-server-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/conscrypt/conscrypt-openjdk-uber/2.5.2/conscrypt-openjdk-uber-2.5.2.jar:/Users/nha/.m2/repository/org/eclipse/jetty/jetty-alpn-server/9.4.42.v20210604/jetty-alpn-server-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/eclipse/jetty/jetty-servlet/9.4.42.v20210604/jetty-servlet-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/eclipse/jetty/jetty-security/9.4.42.v20210604/jetty-security-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/eclipse/jetty/jetty-util-ajax/9.4.42.v20210604/jetty-util-ajax-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/eclipse/jetty/jetty-servlets/9.4.42.v20210604/jetty-servlets-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/eclipse/jetty/jetty-continuation/9.4.42.v20210604/jetty-continuation-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/eclipse/jetty/jetty-util/9.4.42.v20210604/jetty-util-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/glassfish/jersey/core/jersey-server/2.34/jersey-server-2.34.jar:/Users/nha/.m2/repository/org/glassfish/jersey/core/jersey-common/2.34/jersey-common-2.34.jar:/Users/nha/.m2/repository/org/glassfish/hk2/osgi-resource-locator/1.0.3/osgi-resource-locator-1.0.3.jar:/Users/nha/.m2/repository/jakarta/ws/rs/jakarta.ws.rs-api/2.1.6/jakarta.ws.rs-api-2.1.6.jar:/Users/nha/.m2/repository/jakarta/annotation/jakarta.annotation-api/1.3.5/jakarta.annotation-api-1.3.5.jar:/Users/nha/.m2/repository/org/glassfish/hk2/external/jakarta.inject/2.6.1/jakarta.inject-2.6.1.jar:/Users/nha/.m2/repository/jakarta/validation/jakarta.validation-api/2.0.2/jakarta.validation-api-2.0.2.jar:/Users/nha/.m2/repository/org/glassfish/jersey/containers/jersey-container-servlet-core/2.34/jersey-container-servlet-core-2.34.jar:/Users/nha/.m2/repository/org/glassfish/jersey/containers/jersey-container-servlet/2.34/jersey-container-servlet-2.34.jar:/Users/nha/.m2/repository/org/glassfish/jersey/media/jersey-media-json-jackson/2.34/jersey-media-json-jackson-2.34.jar:/Users/nha/.m2/repository/org/glassfish/jersey/ext/jersey-entity-filtering/2.34/jersey-entity-filtering-2.34.jar:/Users/nha/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.12.3/jackson-annotations-2.12.3.jar:/Users/nha/.m2/repository/com/fasterxml/jackson/module/jackson-module-jaxb-annotations/2.12.3/jackson-module-jaxb-annotations-2.12.3.jar:/Users/nha/.m2/repository/jakarta/xml/bind/jakarta.xml.bind-api/2.3.3/jakarta.xml.bind-api-2.3.3.jar:/Users/nha/.m2/repository/jakarta/activation/jakarta.activation-api/1.2.2/jakarta.activation-api-1.2.2.jar:/Users/nha/.m2/repository/com/fasterxml/jackson/jaxrs/jackson-jaxrs-json-provider/2.12.3/jackson-jaxrs-json-provider-2.12.3.jar:/Users/nha/.m2/repository/com/fasterxml/jackson/jaxrs/jackson-jaxrs-base/2.12.3/jackson-jaxrs-base-2.12.3.jar:/Users/nha/.m2/repository/org/glassfish/jersey/inject/jersey-hk2/2.34/jersey-hk2-2.34.jar:/Users/nha/.m2/repository/org/glassfish/hk2/hk2-locator/2.6.1/hk2-locator-2.6.1.jar:/Users/nha/.m2/repository/org/glassfish/hk2/external/aopalliance-repackaged/2.6.1/aopalliance-repackaged-2.6.1.jar:/Users/nha/.m2/repository/org/glassfish/hk2/hk2-api/2.6.1/hk2-api-2.6.1.jar:/Users/nha/.m2/repository/org/glassfish/hk2/hk2-utils/2.6.1/hk2-utils-2.6.1.jar:/Users/nha/.m2/repository/org/javassist/javassist/3.25.0-GA/javassist-3.25.0-GA.jar:/Users/nha/.m2/repository/com/fasterxml/jackson/module/jackson-module-jsonSchema/2.12.3/jackson-module-jsonSchema-2.12.3.jar:/Users/nha/.m2/repository/javax/validation/validation-api/1.1.0.Final/validation-api-1.1.0.Final.jar:/Users/nha/.m2/repository/org/slf4j/jul-to-slf4j/1.7.25/jul-to-slf4j-1.7.25.jar:/Users/nha/.m2/repository/org/slf4j/jcl-over-slf4j/1.7.25/jcl-over-slf4j-1.7.25.jar:/Users/nha/.m2/repository/com/google/guava/guava/30.1-jre/guava-30.1-jre.jar:/Users/nha/.m2/repository/com/google/guava/failureaccess/1.0.1/failureaccess-1.0.1.jar:/Users/nha/.m2/repository/com/google/guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/Users/nha/.m2/repository/org/checkerframework/checker-qual/3.5.0/checker-qual-3.5.0.jar:/Users/nha/.m2/repository/com/google/errorprone/error_prone_annotations/2.5.1/error_prone_annotations-2.5.1.jar:/Users/nha/.m2/repository/com/google/j2objc/j2objc-annotations/1.3/j2objc-annotations-1.3.jar:/Users/nha/.m2/repository/com/beust/jcommander/1.78/jcommander-1.78.jar:/Users/nha/.m2/repository/io/swagger/swagger-annotations/1.6.2/swagger-annotations-1.6.2.jar:/Users/nha/.m2/repository/io/prometheus/simpleclient/0.5.0/simpleclient-0.5.0.jar:/Users/nha/.m2/repository/io/prometheus/simpleclient_jetty/0.5.0/simpleclient_jetty-0.5.0.jar:/Users/nha/.m2/repository/io/prometheus/simpleclient_hotspot/0.5.0/simpleclient_hotspot-0.5.0.jar:/Users/nha/.m2/repository/io/swagger/swagger-core/1.6.2/swagger-core-1.6.2.jar:/Users/nha/.m2/repository/io/swagger/swagger-models/1.6.2/swagger-models-1.6.2.jar:/Users/nha/.m2/repository/org/hdrhistogram/HdrHistogram/2.1.9/HdrHistogram-2.1.9.jar:/Users/nha/.m2/repository/com/google/code/gson/gson/2.8.6/gson-2.8.6.jar:/Users/nha/.m2/repository/com/github/zafarkhaja/java-semver/0.9.0/java-semver-0.9.0.jar:/Users/nha/.m2/repository/org/apache/avro/avro/1.10.2/avro-1.10.2.jar:/Users/nha/.m2/repository/org/apache/commons/commons-compress/1.19/commons-compress-1.19.jar:/Users/nha/.m2/repository/com/carrotsearch/hppc/0.7.3/hppc-0.7.3.jar:/Users/nha/.m2/repository/javax/xml/bind/jaxb-api/2.3.1/jaxb-api-2.3.1.jar:/Users/nha/.m2/repository/com/sun/activation/javax.activation/1.2.0/javax.activation-1.2.0.jar:/Users/nha/repo/pulsar/pulsar-transaction/coordinator/target/pulsar-transaction-coordinator.jar:/Users/nha/repo/pulsar/pulsar-package-management/core/target/pulsar-package-core.jar:/Users/nha/repo/pulsar/pulsar-discovery-service/target/pulsar-discovery-service.jar:/Users/nha/repo/pulsar/pulsar-common/target/pulsar-common.jar:/Users/nha/.m2/repository/io/netty/netty-transport-native-unix-common/4.1.63.Final/netty-transport-native-unix-common-4.1.63.Final-linux-x86_64.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/cpu-affinity/4.14.1/cpu-affinity-4.14.1.jar:/Users/nha/.m2/repository/io/airlift/aircompressor/0.16/aircompressor-0.16.jar:/Users/nha/.m2/repository/io/netty/netty-codec-haproxy/4.1.63.Final/netty-codec-haproxy-4.1.63.Final.jar:/Users/nha/repo/pulsar/bouncy-castle/bc/target/bouncy-castle-bc-2.8.0-pkg.jar:/Users/nha/.m2/repository/org/bouncycastle/bcpkix-jdk15on/1.68/bcpkix-jdk15on-1.68.jar:/Users/nha/.m2/repository/org/bouncycastle/bcprov-jdk15on/1.68/bcprov-jdk15on-1.68.jar:/Users/nha/.m2/repository/org/bouncycastle/bcprov-ext-jdk15on/1.68/bcprov-ext-jdk15on-1.68.jar:/Users/nha/repo/pulsar/pulsar-proxy/target/pulsar-proxy.jar:/Users/nha/.m2/repository/org/eclipse/jetty/jetty-proxy/9.4.42.v20210604/jetty-proxy-9.4.42.v20210604.jar:/Users/nha/.m2/repository/org/eclipse/jetty/jetty-client/9.4.42.v20210604/jetty-client-9.4.42.v20210604.jar:/Users/nha/.m2/repository/io/prometheus/simpleclient_servlet/0.5.0/simpleclient_servlet-0.5.0.jar:/Users/nha/.m2/repository/io/prometheus/simpleclient_common/0.5.0/simpleclient_common-0.5.0.jar:/Users/nha/repo/pulsar/pulsar-broker-auth-sasl/target/pulsar-broker-auth-sasl.jar:/Users/nha/repo/pulsar/pulsar-client-auth-sasl/target/pulsar-client-auth-sasl.jar:/Users/nha/.m2/repository/javax/ws/rs/javax.ws.rs-api/2.1/javax.ws.rs-api-2.1.jar:/Users/nha/.m2/repository/org/glassfish/jersey/core/jersey-client/2.34/jersey-client-2.34.jar:/Users/nha/.m2/repository/org/apache/zookeeper/zookeeper-prometheus-metrics/3.6.3/zookeeper-prometheus-metrics-3.6.3.jar:/Users/nha/.m2/repository/org/apache/zookeeper/zookeeper/3.6.3/zookeeper-3.6.3.jar:/Users/nha/.m2/repository/org/apache/zookeeper/zookeeper-jute/3.6.3/zookeeper-jute-3.6.3.jar:/Users/nha/.m2/repository/org/apache/yetus/audience-annotations/0.5.0/audience-annotations-0.5.0.jar:/Users/nha/.m2/repository/io/netty/netty-transport-native-epoll/4.1.63.Final/netty-transport-native-epoll-4.1.63.Final.jar:/Users/nha/repo/pulsar/pulsar-package-management/bookkeeper-storage/target/pulsar-package-bookkeeper-storage.jar:/Users/nha/.m2/repository/org/apache/distributedlog/distributedlog-core/4.14.1/distributedlog-core-4.14.1.jar:/Users/nha/.m2/repository/org/apache/distributedlog/distributedlog-protocol/4.14.1/distributedlog-protocol-4.14.1.jar:/Users/nha/.m2/repository/org/apache/distributedlog/distributedlog-common/4.14.1/distributedlog-common-4.14.1.jar:/Users/nha/.m2/repository/org/apache/thrift/libthrift/0.12.0/libthrift-0.12.0.jar:/Users/nha/repo/pulsar/testmocks/target/testmocks.jar:/Users/nha/repo/pulsar/pulsar-client-tools/target/pulsar-client-tools.jar:/Users/nha/repo/pulsar/pulsar-client-admin-api/target/pulsar-client-admin-api.jar:/Users/nha/.m2/repository/commons-io/commons-io/2.8.0/commons-io-2.8.0.jar:/Users/nha/repo/pulsar/pulsar-client-messagecrypto-bc/target/pulsar-client-messagecrypto-bc.jar:/Users/nha/.m2/repository/org/asynchttpclient/async-http-client/2.12.1/async-http-client-2.12.1.jar:/Users/nha/.m2/repository/org/asynchttpclient/async-http-client-netty-utils/2.12.1/async-http-client-netty-utils-2.12.1.jar:/Users/nha/.m2/repository/org/reactivestreams/reactive-streams/1.0.3/reactive-streams-1.0.3.jar:/Users/nha/.m2/repository/com/typesafe/netty/netty-reactive-streams/2.0.4/netty-reactive-streams-2.0.4.jar:/Users/nha/repo/pulsar/pulsar-testclient/target/pulsar-testclient.jar:/Users/nha/.m2/repository/commons-configuration/commons-configuration/1.10/commons-configuration-1.10.jar:/Users/nha/.m2/repository/commons-lang/commons-lang/2.6/commons-lang-2.6.jar:/Users/nha/.m2/repository/commons-logging/commons-logging/1.1.1/commons-logging-1.1.1.jar:/Users/nha/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.12.3/jackson-databind-2.12.3.jar:/Users/nha/.m2/repository/org/apache/logging/log4j/log4j-1.2-api/2.14.0/log4j-1.2-api-2.14.0.jar:/Users/nha/.m2/repository/org/apache/logging/log4j/log4j-api/2.14.0/log4j-api-2.14.0.jar:/Users/nha/.m2/repository/org/apache/logging/log4j/log4j-core/2.14.0/log4j-core-2.14.0.jar:/Users/nha/.m2/repository/org/apache/logging/log4j/log4j-web/2.14.0/log4j-web-2.14.0.jar:/Users/nha/.m2/repository/io/dropwizard/metrics/metrics-core/3.2.5/metrics-core-3.2.5.jar:/Users/nha/.m2/repository/io/dropwizard/metrics/metrics-graphite/3.2.5/metrics-graphite-3.2.5.jar:/Users/nha/.m2/repository/io/dropwizard/metrics/metrics-jvm/3.2.5/metrics-jvm-3.2.5.jar:/Users/nha/.m2/repository/org/xerial/snappy/snappy-java/1.1.7/snappy-java-1.1.7.jar:/Users/nha/.m2/repository/com/fasterxml/jackson/dataformat/jackson-dataformat-yaml/2.12.3/jackson-dataformat-yaml-2.12.3.jar:/Users/nha/.m2/repository/org/yaml/snakeyaml/1.27/snakeyaml-1.27.jar:/Users/nha/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.12.3/jackson-core-2.12.3.jar:/Users/nha/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.14.0/log4j-slf4j-impl-2.14.0.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/stats/prometheus-metrics-provider/4.14.1/prometheus-metrics-provider-4.14.1.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/stats/bookkeeper-stats-api/4.14.1/bookkeeper-stats-api-4.14.1.jar:/Users/nha/.m2/repository/io/netty/netty-common/4.1.63.Final/netty-common-4.1.63.Final.jar:/Users/nha/.m2/repository/com/yahoo/datasketches/sketches-core/0.8.3/sketches-core-0.8.3.jar:/Users/nha/.m2/repository/com/yahoo/datasketches/memory/0.8.3/memory-0.8.3.jar:/Users/nha/.m2/repository/io/prometheus/simpleclient_log4j2/0.5.0/simpleclient_log4j2-0.5.0.jar:/Users/nha/repo/pulsar/pulsar-functions/worker/target/pulsar-functions-worker.jar:/Users/nha/repo/pulsar/pulsar-functions/runtime/target/pulsar-functions-runtime.jar:/Users/nha/repo/pulsar/pulsar-functions/instance/target/pulsar-functions-instance.jar:/Users/nha/repo/pulsar/pulsar-functions/utils/target/pulsar-functions-utils.jar:/Users/nha/repo/pulsar/pulsar-config-validation/target/pulsar-config-validation.jar:/Users/nha/repo/pulsar/pulsar-io/core/target/pulsar-io-core.jar:/Users/nha/repo/pulsar/pulsar-functions/api-java/target/pulsar-functions-api.jar:/Users/nha/.m2/repository/net/jodah/typetools/0.5.0/typetools-0.5.0.jar:/Users/nha/.m2/repository/io/prometheus/simpleclient_httpserver/0.5.0/simpleclient_httpserver-0.5.0.jar:/Users/nha/.m2/repository/io/prometheus/jmx/collector/0.14.0/collector-0.14.0.jar:/Users/nha/repo/pulsar/pulsar-functions/secrets/target/pulsar-functions-secrets.jar:/Users/nha/repo/pulsar/pulsar-functions/proto/target/pulsar-functions-proto.jar:/Users/nha/.m2/repository/io/kubernetes/client-java/12.0.0/client-java-12.0.0.jar:/Users/nha/.m2/repository/io/kubernetes/client-java-api/12.0.0/client-java-api-12.0.0.jar:/Users/nha/.m2/repository/com/squareup/okhttp3/okhttp/3.14.9/okhttp-3.14.9.jar:/Users/nha/.m2/repository/com/squareup/okhttp3/logging-interceptor/3.14.9/logging-interceptor-3.14.9.jar:/Users/nha/.m2/repository/io/gsonfire/gson-fire/1.8.5/gson-fire-1.8.5.jar:/Users/nha/.m2/repository/io/kubernetes/client-java-proto/12.0.0/client-java-proto-12.0.0.jar:/Users/nha/.m2/repository/org/bitbucket/b_c/jose4j/0.7.6/jose4j-0.7.6.jar:/Users/nha/.m2/repository/org/glassfish/jersey/media/jersey-media-multipart/2.34/jersey-media-multipart-2.34.jar:/Users/nha/.m2/repository/org/jvnet/mimepull/mimepull/1.9.13/mimepull-1.9.13.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/bookkeeper-server/4.14.1/bookkeeper-server-4.14.1.jar:/Users/nha/repo/pulsar/pulsar-functions/localrun/target/pulsar-functions-local-runner-original.jar:/Users/nha/.m2/repository/io/grpc/grpc-all/1.33.0/grpc-all-1.33.0.jar:/Users/nha/.m2/repository/io/grpc/grpc-api/1.33.0/grpc-api-1.33.0.jar:/Users/nha/.m2/repository/org/codehaus/mojo/animal-sniffer-annotations/1.18/animal-sniffer-annotations-1.18.jar:/Users/nha/.m2/repository/io/grpc/grpc-auth/1.33.0/grpc-auth-1.33.0.jar:/Users/nha/.m2/repository/com/google/auth/google-auth-library-credentials/0.20.0/google-auth-library-credentials-0.20.0.jar:/Users/nha/.m2/repository/io/grpc/grpc-context/1.33.0/grpc-context-1.33.0.jar:/Users/nha/.m2/repository/io/grpc/grpc-core/1.33.0/grpc-core-1.33.0.jar:/Users/nha/.m2/repository/com/google/android/annotations/4.1.1.4/annotations-4.1.1.4.jar:/Users/nha/.m2/repository/io/grpc/grpc-grpclb/1.33.0/grpc-grpclb-1.33.0.jar:/Users/nha/.m2/repository/com/google/protobuf/protobuf-java-util/3.11.4/protobuf-java-util-3.11.4.jar:/Users/nha/.m2/repository/io/grpc/grpc-netty/1.33.0/grpc-netty-1.33.0.jar:/Users/nha/.m2/repository/io/grpc/grpc-okhttp/1.33.0/grpc-okhttp-1.33.0.jar:/Users/nha/.m2/repository/com/squareup/okhttp/okhttp/2.7.4/okhttp-2.7.4.jar:/Users/nha/.m2/repository/com/squareup/okio/okio/1.13.0/okio-1.13.0.jar:/Users/nha/.m2/repository/io/grpc/grpc-protobuf/1.33.0/grpc-protobuf-1.33.0.jar:/Users/nha/.m2/repository/com/google/api/grpc/proto-google-common-protos/1.17.0/proto-google-common-protos-1.17.0.jar:/Users/nha/.m2/repository/io/grpc/grpc-protobuf-lite/1.33.0/grpc-protobuf-lite-1.33.0.jar:/Users/nha/.m2/repository/io/grpc/grpc-services/1.33.0/grpc-services-1.33.0.jar:/Users/nha/.m2/repository/io/grpc/grpc-stub/1.33.0/grpc-stub-1.33.0.jar:/Users/nha/.m2/repository/io/grpc/grpc-xds/1.33.0/grpc-xds-1.33.0.jar:/Users/nha/.m2/repository/io/grpc/grpc-alts/1.33.0/grpc-alts-1.33.0.jar:/Users/nha/.m2/repository/com/google/auth/google-auth-library-oauth2-http/0.20.0/google-auth-library-oauth2-http-0.20.0.jar:/Users/nha/.m2/repository/com/google/re2j/re2j/1.2/re2j-1.2.jar:/Users/nha/.m2/repository/io/opencensus/opencensus-proto/0.2.0/opencensus-proto-0.2.0.jar:/Users/nha/.m2/repository/io/grpc/grpc-netty-shaded/1.33.0/grpc-netty-shaded-1.33.0.jar:/Users/nha/.m2/repository/io/perfmark/perfmark-api/0.19.0/perfmark-api-0.19.0.jar:/Users/nha/.m2/repository/com/google/code/findbugs/jsr305/3.0.2/jsr305-3.0.2.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/http/vertx-http-server/4.14.1/vertx-http-server-4.14.1.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/http/http-server/4.14.1/http-server-4.14.1.jar:/Users/nha/.m2/repository/io/vertx/vertx-core/3.5.4/vertx-core-3.5.4.jar:/Users/nha/.m2/repository/io/netty/netty-buffer/4.1.63.Final/netty-buffer-4.1.63.Final.jar:/Users/nha/.m2/repository/io/netty/netty-handler/4.1.63.Final/netty-handler-4.1.63.Final.jar:/Users/nha/.m2/repository/io/netty/netty-codec/4.1.63.Final/netty-codec-4.1.63.Final.jar:/Users/nha/.m2/repository/io/netty/netty-handler-proxy/4.1.63.Final/netty-handler-proxy-4.1.63.Final.jar:/Users/nha/.m2/repository/io/netty/netty-codec-socks/4.1.63.Final/netty-codec-socks-4.1.63.Final.jar:/Users/nha/.m2/repository/io/netty/netty-codec-http/4.1.63.Final/netty-codec-http-4.1.63.Final.jar:/Users/nha/.m2/repository/io/netty/netty-codec-http2/4.1.63.Final/netty-codec-http2-4.1.63.Final.jar:/Users/nha/.m2/repository/io/netty/netty-resolver/4.1.63.Final/netty-resolver-4.1.63.Final.jar:/Users/nha/.m2/repository/io/netty/netty-resolver-dns/4.1.63.Final/netty-resolver-dns-4.1.63.Final.jar:/Users/nha/.m2/repository/io/netty/netty-codec-dns/4.1.63.Final/netty-codec-dns-4.1.63.Final.jar:/Users/nha/.m2/repository/io/vertx/vertx-web/3.5.4/vertx-web-3.5.4.jar:/Users/nha/.m2/repository/io/vertx/vertx-auth-common/3.5.4/vertx-auth-common-3.5.4.jar:/Users/nha/.m2/repository/io/vertx/vertx-bridge-common/3.5.4/vertx-bridge-common-3.5.4.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/bookkeeper-common/4.14.1/bookkeeper-common-4.14.1.jar:/Users/nha/.m2/repository/org/jctools/jctools-core/2.1.2/jctools-core-2.1.2.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/bookkeeper-common-allocator/4.14.1/bookkeeper-common-allocator-4.14.1.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/bookkeeper-proto/4.14.1/bookkeeper-proto-4.14.1.jar:/Users/nha/.m2/repository/org/rocksdb/rocksdbjni/6.10.2/rocksdbjni-6.10.2.jar:/Users/nha/.m2/repository/io/netty/netty-transport-native-epoll/4.1.63.Final/netty-transport-native-epoll-4.1.63.Final-linux-x86_64.jar:/Users/nha/.m2/repository/io/netty/netty-transport-native-unix-common/4.1.63.Final/netty-transport-native-unix-common-4.1.63.Final.jar:/Users/nha/.m2/repository/io/netty/netty-tcnative-boringssl-static/2.0.38.Final/netty-tcnative-boringssl-static-2.0.38.Final.jar:/Users/nha/.m2/repository/org/apache/bookkeeper/circe-checksum/4.14.1/circe-checksum-4.14.1.jar:/Users/nha/.m2/repository/commons-cli/commons-cli/1.2/commons-cli-1.2.jar:/Users/nha/.m2/repository/org/apache/commons/commons-collections4/4.1/commons-collections4-4.1.jar:/Users/nha/.m2/repository/net/java/dev/jna/jna/4.2.0/jna-4.2.0.jar:/Users/nha/.m2/repository/org/apache/httpcomponents/httpclient/4.5.13/httpclient-4.5.13.jar:/Users/nha/.m2/repository/org/apache/httpcomponents/httpcore/4.4.13/httpcore-4.4.13.jar: | |
| 09:01:56.102 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.library.path=/Users/nha/Library/Java/Extensions:/Library/Java/Extensions:/Network/Library/Java/Extensions:/System/Library/Java/Extensions:/usr/lib/java:. | |
| 09:01:56.102 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.io.tmpdir=/var/folders/c9/rnfrx45x4j90r4cn5cxcxws00000gn/T/ | |
| 09:01:56.102 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.compiler=<NA> | |
| 09:01:56.103 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.name=Mac OS X | |
| 09:01:56.103 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.arch=x86_64 | |
| 09:01:56.103 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.version=10.14.6 | |
| 09:01:56.103 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.name=nha | |
| 09:01:56.103 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.home=/Users/nha | |
| 09:01:56.103 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.dir=/Users/nha/repo/pulsar | |
| 09:01:56.104 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.free=1895MB | |
| 09:01:56.104 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.max=2048MB | |
| 09:01:56.104 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.total=2048MB | |
| 09:01:56.124 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1 sessionTimeout=30000 watcher=org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@55e7a35c | |
| 09:01:56.133 [main] INFO org.apache.zookeeper.common.X509Util - Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation | |
| 09:01:56.139 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes | |
| 09:01:56.156 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false | |
| 09:01:56.179 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181. | |
| 09:01:56.180 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error) | |
| 09:01:56.206 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:58308, server: localhost/127.0.0.1:2181 | |
| 09:01:56.225 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x100047ee99f001a, negotiated timeout = 30000 | |
| 09:01:56.230 [main-EventThread] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now. | |
| 09:01:56.233 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=30000 watcher=org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@4a9419d7 | |
| 09:01:56.233 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes | |
| 09:01:56.233 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false | |
| 09:01:56.235 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181. | |
| 09:01:56.236 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error) | |
| 09:01:56.236 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:58309, server: localhost/127.0.0.1:2181 | |
| 09:01:56.247 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x100047ee99f001b, negotiated timeout = 30000 | |
| 09:01:56.248 [main-EventThread] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now. | |
| 09:01:56.531 [main] INFO org.apache.pulsar.broker.authorization.AuthorizationService - org.apache.pulsar.broker.authorization.PulsarAuthorizationProvider has been loaded. | |
| 09:01:56.736 [main] INFO org.apache.pulsar.proxy.server.ProxyService - Started Pulsar Proxy at /0.0.0.0:6660 | |
| 09:01:56.932 [main] INFO org.eclipse.jetty.server.Server - jetty-9.4.42.v20210604; built: 2021-06-04T17:33:38.939Z; git: 5cd5e6d2375eeab146813b0de9f19eda6ab6e6cb; jvm 11.0.10+8-jvmci-21.0-b06 | |
| 09:01:56.974 [main] INFO org.eclipse.jetty.server.session - DefaultSessionIdManager workerName=node0 | |
| 09:01:56.975 [main] INFO org.eclipse.jetty.server.session - No SessionScavenger set, using defaults | |
| 09:01:56.978 [main] INFO org.eclipse.jetty.server.session - node0 Scavenging every 660000ms | |
| 09:01:56.995 [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@24a298a6{/metrics,null,AVAILABLE} | |
| 09:01:57.360 [main] WARN org.glassfish.jersey.server.wadl.WadlFeature - JAXBContext implementation could not be found. WADL feature is disabled. | |
| 09:01:57.613 [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@27f74733{/,null,AVAILABLE} | |
| 09:01:57.704 [main] WARN org.glassfish.jersey.server.wadl.WadlFeature - JAXBContext implementation could not be found. WADL feature is disabled. | |
| 09:01:57.838 [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@982bb90{/proxy-stats,null,AVAILABLE} | |
| 09:01:57.931 [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@5aae8eb5{/admin,null,AVAILABLE} | |
| 09:01:57.934 [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@76954a33{/lookup,null,AVAILABLE} | |
| 09:01:57.974 [main] INFO org.eclipse.jetty.server.AbstractConnector - Started ServerConnector@63cd604c{HTTP/1.1, (http/1.1)}{0.0.0.0:8082} | |
| 09:01:57.979 [main] INFO org.eclipse.jetty.server.Server - Started @4172ms | |
| 09:01:57.982 [main] INFO org.apache.pulsar.proxy.server.WebServer - Server started at end point http://0.0.0.0:8082 | |
| 09:03:17.305 [pulsar-proxy-io-2-1] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58370] New connection opened | |
| 09:03:17.467 [pulsar-proxy-io-2-1] WARN io.netty.resolver.dns.DnsServerAddressStreamProviders - Can not find io.netty.resolver.dns.macos.MacOSDnsServerAddressStreamProvider in the classpath, fallback to system defaults. This may result in incorrect DNS resolutions on MacOS. | |
| 09:03:17.586 [pulsar-proxy-io-2-1] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58370] complete connection, init proxy handler. authenticated with none role null, hasProxyToBrokerUrl: false | |
| 09:03:17.705 [pulsar-proxy-io-2-3] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xf5d61fe6, L:/127.0.0.1:58371 - R:/127.0.0.1:6650]] Connected to server | |
| 09:03:17.807 [pulsar-proxy-io-2-5] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x4f88549b, L:/127.0.0.1:58372 - R:/127.0.0.1:6650]] Connected to server | |
| 09:03:17.851 [pulsar-proxy-io-2-7] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58373] New connection opened | |
| 09:03:17.866 [pulsar-proxy-io-2-7] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58373] complete connection, init proxy handler. authenticated with none role null, hasProxyToBrokerUrl: true | |
| 09:03:17.903 [pulsar-proxy-io-2-7] INFO org.apache.pulsar.client.impl.PulsarClientImpl - Client closing. URL: pulsar://192.168.1.38:6660/ | |
| 09:03:17.905 [pulsar-proxy-io-2-7] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58373] Connection closed | |
| 09:03:18.017 [pulsar-proxy-io-2-1] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58374] New connection opened | |
| 09:03:18.018 [pulsar-proxy-io-2-1] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58374] complete connection, init proxy handler. authenticated with none role null, hasProxyToBrokerUrl: true | |
| 09:03:18.020 [pulsar-proxy-io-2-1] INFO org.apache.pulsar.client.impl.PulsarClientImpl - Client closing. URL: pulsar://192.168.1.38:6660/ | |
| 09:03:18.021 [pulsar-proxy-io-2-1] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58374] Connection closed | |
| 09:03:18.216 [pulsar-proxy-io-2-3] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58375] New connection opened | |
| 09:03:18.219 [pulsar-proxy-io-2-3] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58375] complete connection, init proxy handler. authenticated with none role null, hasProxyToBrokerUrl: true | |
| 09:03:18.220 [pulsar-proxy-io-2-3] INFO org.apache.pulsar.client.impl.PulsarClientImpl - Client closing. URL: pulsar://192.168.1.38:6660/ | |
| 09:03:18.227 [pulsar-proxy-io-2-3] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58375] Connection closed | |
| 09:03:18.628 [pulsar-proxy-io-2-5] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58376] New connection opened | |
| 09:03:18.630 [pulsar-proxy-io-2-5] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58376] complete connection, init proxy handler. authenticated with none role null, hasProxyToBrokerUrl: true | |
| 09:03:18.631 [pulsar-proxy-io-2-5] INFO org.apache.pulsar.client.impl.PulsarClientImpl - Client closing. URL: pulsar://192.168.1.38:6660/ | |
| 09:03:18.632 [pulsar-proxy-io-2-5] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58376] Connection closed | |
| 09:03:19.383 [pulsar-proxy-io-2-7] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58377] New connection opened | |
| 09:03:19.385 [pulsar-proxy-io-2-7] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58377] complete connection, init proxy handler. authenticated with none role null, hasProxyToBrokerUrl: true | |
| 09:03:19.386 [pulsar-proxy-io-2-7] INFO org.apache.pulsar.client.impl.PulsarClientImpl - Client closing. URL: pulsar://192.168.1.38:6660/ | |
| 09:03:19.386 [pulsar-proxy-io-2-7] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58377] Connection closed | |
| 09:03:20.843 [pulsar-proxy-io-2-1] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58378] New connection opened | |
| 09:03:20.844 [pulsar-proxy-io-2-1] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58378] complete connection, init proxy handler. authenticated with none role null, hasProxyToBrokerUrl: true | |
| 09:03:20.845 [pulsar-proxy-io-2-1] INFO org.apache.pulsar.client.impl.PulsarClientImpl - Client closing. URL: pulsar://192.168.1.38:6660/ | |
| 09:03:20.846 [pulsar-proxy-io-2-1] INFO org.apache.pulsar.proxy.server.ProxyConnection - [/127.0.0.1:58378] Connection closed |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Because of a warning when starting up the proxy | |
| ```Unable to load io.netty.resolver.dns.macos.MacOSDnsServerAddressStreamProvider, fallback to system defaults. This may result in incorrect DNS resolutions on MacOS.``` | |
| I tried adding the following dependency in pulsar/pom.xml | |
| The warning goes away | |
| <dependency> | |
| <groupId>io.netty</groupId> | |
| <artifactId>netty-resolver-dns-native-macos</artifactId> | |
| <version>4.1.63.Final</version> | |
| <classifier>osx-x86_64</classifier> | |
| </dependency> | |
| Here is the command I use to build pulsar ```mvn install -Pcore-modules,-main -DskipTests -Dlicense.skip && mvn -pl pulsar-proxy install -DskipTests -Dlicense.skip``` | |
| I am using the 2.8.0 commit https://github.com/apache/pulsar/commit/89ac98e4af363b09f2fe8e309539b0e35243aaee |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment