Uploaded image for project: 'Couchbase Kafka Connector'
  1. Couchbase Kafka Connector
  2. KAFKAC-165

Source: Cannot connect to Couchbase on custom port

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 3.4.7
    • Labels:
      None
    • Story Points:
      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

          No reviews matched the request. Check your Options in the drop-down menu of this sections header.

            Activity

            david.nault David Nault created issue -
            david.nault David Nault made changes -
            Field Original Value New Value
            Link This issue blocks CBSE-8057 [ CBSE-8057 ]
            david.nault David Nault made changes -
            Status New [ 10003 ] Open [ 1 ]
            david.nault David Nault made changes -
            Status Open [ 1 ] In Progress [ 3 ]
            Hide
            michael.reiche Michael Reiche added a comment -

            cbc also says it ignores any port specification in the -U argument.

            Show
            michael.reiche Michael Reiche added a comment - cbc also says it ignores any port specification in the -U argument.
            Hide
            david.nault David Nault added a comment -

            cbc also says it ignores any port specification in the -U argument.

            Interesting. Let's track that with a separate Jira ticket.

            Show
            david.nault David Nault added a comment - cbc also says it ignores any port specification in the -U argument. Interesting. Let's track that with a separate Jira ticket.
            david.nault David Nault made changes -
            Summary Cannot connect to Couchbase on custom port Source: Cannot connect to Couchbase on custom port
            david.nault David Nault made changes -
            Link This issue relates to KAFKAC-167 [ KAFKAC-167 ]
            david.nault David Nault made changes -
            Description Attempting to connect using a custom port results in an error.

            Example config snippet:
            {noformat}connection.cluster_address=192.168.64.4:30711
            {noformat}
            Error message:
            {noformat}[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
            {noformat}
            Attempting to connect using a custom port with the Source connector results in an error.

            Example config snippet:
            {noformat}connection.cluster_address=192.168.64.4:30711
            {noformat}
            Error message:
            {noformat}[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
            {noformat}
            david.nault David Nault made changes -
            Resolution Fixed [ 1 ]
            Status In Progress [ 3 ] Resolved [ 5 ]
            brett19 Brett Lawson made changes -
            Story Points 1

              People

              Assignee:
              david.nault David Nault
              Reporter:
              david.nault David Nault
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Dates

                Created:
                Updated:
                Resolved:

                  Gerrit Reviews

                  There are no open Gerrit changes

                    PagerDuty