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

Source: Cannot connect to Couchbase on custom port

    XMLWordPrintable

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 3.4.7
    • 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

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

          Activity

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

            michael.reiche Michael Reiche added a comment - cbc also says it ignores any port specification in the -U argument.
            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 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.

            People

              david.nault David Nault
              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