You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@pulsar.apache.org by Apache Pulsar Slack <ap...@gmail.com> on 2019/06/23 09:11:03 UTC
Slack digest for #general - 2019-06-23
2019-06-22 09:31:46 UTC - Jan-Pieter George: @Jan-Pieter George has joined the channel
----
2019-06-22 10:46:14 UTC - Ravi Raj B: @Ravi Raj B has joined the channel
----
2019-06-22 14:39:06 UTC - Sinan Bir: @Chris Bartholomew ye it's configured as you specified. Still got same error. I can pass authentication part. After Auhentication it fails on authMode section.
"Authenticated WebSocket client {} on topic {}"
14:35:16.977 [pulsar-client-io-41-6] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xadc41497, L:/10.6.0.248:35992 - R:10.6.0.248/10.6.0.248:6650]] Connected to server
14:35:17.076 [pulsar-io-21-3] INFO org.apache.pulsar.broker.service.ServerCnx - New connection from /10.6.0.248:35992
14:35:17.077 [pulsar-io-21-3] WARN org.apache.pulsar.broker.service.ServerCnx - [/10.6.0.248:35992] Unable to authenticate: Unsupported authentication mode: none
14:35:17.078 [pulsar-io-21-3] INFO org.apache.pulsar.broker.service.ServerCnx - Closed connection from /10.6.0.248:35992
14:35:17.078 [pulsar-client-io-41-6] WARN org.apache.pulsar.client.impl.ClientCnx - [10.6.0.248/10.6.0.248:6650] Got exception IllegalArgumentException : null
java.lang.IllegalArgumentException: null
at com.google.common.base.Preconditions.checkArgument(Preconditions.java:108) ~[com.google.guava-guava-21.0.jar:?]
at org.apache.pulsar.client.impl.ClientCnx.handleError(ClientCnx.java:527) ~[org.apache.pulsar-pulsar-client-original-2.3.2.jar:2.3.2]
at org.apache.pulsar.common.api.PulsarDecoder.channelRead(PulsarDecoder.java:157) ~[org.apache.pulsar-pulsar-common-2.3.2.jar:2.3.2]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:799) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:433) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:330) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at
----
2019-06-22 14:39:54 UTC - Sinan Bir: @Chris Bartholomew should I start up separate websocket server ? I'm using websocket embedded with broker
----
2019-06-22 15:00:54 UTC - Chris Bartholomew: @Sinan Bir I run it as a separate websocket server and it works for me. To get that to work, you also need to configure an authentication for when the websocket server connects to the broker. This is what I use in my websocket.conf: ```# Authentication settings of the proxy itself. Used to connect to brokers
brokerClientTlsEnabled=true
brokerClientAuthenticationPlugin=org.apache.pulsar.client.impl.auth.AuthenticationToken
brokerClientAuthenticationParameters=file:///pulsar/token-websocket/websocket.jwt
```. You have to make sure the the role in the token has access to the broker. The easiest way to do this is to configure it as a superuser role.
----
2019-06-22 15:03:15 UTC - Chris Bartholomew: This is just the authentication part. You need to do the other config settings for running it as a standalone: <https://pulsar.apache.org/docs/en/client-libraries-websocket/#running-the-websocket-service>
----