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>
----
