Details
-
Bug
-
Resolution: Fixed
-
Major
-
None
-
None
-
1
Description
Attempting to connect using a custom port with the Source connector results in an error.
Example config snippet:
connection.cluster_address=192.168.64.4:30711
|
Error message:
[2020-03-06 11:34:38,121] WARN Ignoring error for node 192.168.64.4:30711 when getting number of partitions (com.couchbase.connect.kafka.util.Cluster:158)[2020-03-06 11:34:38,121] WARN Ignoring error for node 192.168.64.4:30711 when getting number of partitions (com.couchbase.connect.kafka.util.Cluster:158)java.nio.channels.UnresolvedAddressException at sun.nio.ch.Net.checkAddress(Net.java:101) at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:622) at com.couchbase.client.deps.io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:83) at com.couchbase.client.deps.io.netty.util.internal.SocketUtils$3.run(SocketUtils.java:80) at java.security.AccessController.doPrivileged(Native Method) at com.couchbase.client.deps.io.netty.util.internal.SocketUtils.connect(SocketUtils.java:80) at com.couchbase.client.deps.io.netty.channel.socket.nio.NioSocketChannel.doConnect(NioSocketChannel.java:210) at com.couchbase.client.deps.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.connect(AbstractNioChannel.java:205) at com.couchbase.client.deps.io.netty.channel.DefaultChannelPipeline$HeadContext.connect(DefaultChannelPipeline.java:1236) at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeConnect(AbstractChannelHandlerContext.java:539
|
Attachments
Issue Links
- relates to
-
KAFKAC-167 Sink: Cannot connect to Couchbase on custom port
- Resolved