Confluent Connect with mysql database

[Conal Nicholls]

Hey guys I'm having a lot of trouble trying to configure confluent 3.2.1 kafka to read my local mysql database similar to the JDBC tutorial for sqlite3. 
Could someone give me guidance on how to finish this setup?

http://docs.confluent.io/3.1.1/connect/connect-jdbc/docs/source_connector.html#quickstart

I have successfully run the initial quickstart and the above tutorial but I cannot get my connector to run with mysql

Im running ubuntu 16.04 on a virtual machine, installd mysql through the terminal and the files are located in /var/lib/

Things I have done : 

• Running Kafka through the extracted zip
  
• Downloaded the java-mysql-connector
  
• Made a connectors folder in the root and identified it as CLASSPATH
  

Sidenote: When I ran bin/connect-standalone standalone.properties new-custom-connector.properties  I received this message:

SLF4J: Class path contains multiple SLF4J bindings.

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka-serde-tools/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka-connect-elasticsearch/slf4j-simple-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka-connect-hdfs/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka-connect-s3/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka-connect-storage-common/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka/slf4j-log4j12-1.7.21.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.

SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]

Exception in thread "main" java.io.FileNotFoundException: standalone.properties (No such file or directory)

at java.io.FileInputStream.open0(Native Method)

at java.io.FileInputStream.open(FileInputStream.java:195)

at java.io.FileInputStream.<init>(FileInputStream.java:138)

at java.io.FileInputStream.<init>(FileInputStream.java:93)

at org.apache.kafka.common.utils.Utils.loadProps(Utils.java:488)

at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:64)

mysql-source.properties

• name=test-source-sqlite-jdbc-autoincrement
  
• connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
  
• tasks.max=1
  
• connection.url=jdbc:mysql:kafka.db
  
• user=root
  
• password=admin
  
• auto.create=true
  
• mode=incrementing
  
• incrementing.column.name=id
  
• topic.prefix=test-mysql-jdbc-
  

When I run  ./bin/connect-standalone ./etc/schema-registry/connect-avro-standalone.properties ./etc/kafka-connect-jdbc/mysql-source.properties I get this error : 

/Desktop/confluent-3.2.1$ ./bin/connect-standalone ./etc/schema-registry/connect-avro-standalone.properties ./etc/kafka-connect-jdbc/mysql-source.properties 

SLF4J: Class path contains multiple SLF4J bindings.

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka-serde-tools/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka-connect-elasticsearch/slf4j-simple-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka-connect-hdfs/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka-connect-s3/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka-connect-storage-common/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka/slf4j-log4j12-1.7.21.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.

SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]

[2017-05-09 13:19:56,573] INFO StandaloneConfig values: 

access.control.allow.methods = 

access.control.allow.origin = 

bootstrap.servers = [localhost:9092]

internal.key.converter = class org.apache.kafka.connect.json.JsonConverter

internal.value.converter = class org.apache.kafka.connect.json.JsonConverter

key.converter = class io.confluent.connect.avro.AvroConverter

offset.flush.interval.ms = 60000

offset.flush.timeout.ms = 5000

offset.storage.file.filename = /tmp/connect.offsets

rest.advertised.host.name = null

rest.advertised.port = null

rest.host.name = null

rest.port = 8083

task.shutdown.graceful.timeout.ms = 5000

value.converter = class io.confluent.connect.avro.AvroConverter

 (org.apache.kafka.connect.runtime.standalone.StandaloneConfig:180)

[2017-05-09 13:19:57,016] INFO Logging initialized @7604ms (org.eclipse.jetty.util.log:186)

[2017-05-09 13:19:57,594] INFO AvroConverterConfig values: 

schema.registry.url = [http://localhost:8081]

max.schemas.per.subject = 1000

 (io.confluent.connect.avro.AvroConverterConfig:169)

[2017-05-09 13:19:57,817] INFO AvroDataConfig values: 

schemas.cache.config = 1000

enhanced.avro.schema.support = false

connect.meta.data = true

 (io.confluent.connect.avro.AvroDataConfig:169)

[2017-05-09 13:19:57,820] INFO AvroConverterConfig values: 

schema.registry.url = [http://localhost:8081]

max.schemas.per.subject = 1000

 (io.confluent.connect.avro.AvroConverterConfig:169)

[2017-05-09 13:19:57,820] INFO AvroDataConfig values: 

schemas.cache.config = 1000

enhanced.avro.schema.support = false

connect.meta.data = true

 (io.confluent.connect.avro.AvroDataConfig:169)

[2017-05-09 13:19:57,877] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:50)

[2017-05-09 13:19:57,877] INFO Herder starting (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:71)

[2017-05-09 13:19:57,878] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:119)

[2017-05-09 13:19:57,878] INFO Starting FileOffsetBackingStore with file /tmp/connect.offsets (org.apache.kafka.connect.storage.FileOffsetBackingStore:60)

[2017-05-09 13:19:57,931] INFO Worker started (org.apache.kafka.connect.runtime.Worker:124)

[2017-05-09 13:19:57,933] INFO Herder started (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:73)

[2017-05-09 13:19:57,935] INFO Starting REST server (org.apache.kafka.connect.runtime.rest.RestServer:98)

[2017-05-09 13:19:58,355] INFO jetty-9.2.15.v20160210 (org.eclipse.jetty.server.Server:327)

May 09, 2017 1:20:00 PM org.glassfish.jersey.internal.Errors logErrors

WARNING: The following warnings have been detected: WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.

WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.

WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation.

WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation.

[2017-05-09 13:20:00,670] INFO Started o.e.j.s.ServletContextHandler@46292372{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:744)

[2017-05-09 13:20:00,834] WARN FAILED ServerConnector@3b4ef7{HTTP/1.1}{0.0.0.0:8083}: java.net.BindException: Address already in use (org.eclipse.jetty.util.component.AbstractLifeCycle:212)

java.net.BindException: Address already in use

at sun.nio.ch.Net.bind0(Native Method)

at sun.nio.ch.Net.bind(Net.java:433)

at sun.nio.ch.Net.bind(Net.java:425)

at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223)

at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74)

at org.eclipse.jetty.server.ServerConnector.open(ServerConnector.java:321)

at org.eclipse.jetty.server.AbstractNetworkConnector.doStart(AbstractNetworkConnector.java:80)

at org.eclipse.jetty.server.ServerConnector.doStart(ServerConnector.java:236)

at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)

at org.eclipse.jetty.server.Server.doStart(Server.java:366)

at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)

at org.apache.kafka.connect.runtime.rest.RestServer.start(RestServer.java:145)

at org.apache.kafka.connect.runtime.Connect.start(Connect.java:54)

at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:81)

[2017-05-09 13:20:00,871] WARN FAILED org.eclipse.jetty.server.Server@4a67318f: java.net.BindException: Address already in use (org.eclipse.jetty.util.component.AbstractLifeCycle:212)

java.net.BindException: Address already in use

at sun.nio.ch.Net.bind0(Native Method)

at sun.nio.ch.Net.bind(Net.java:433)

at sun.nio.ch.Net.bind(Net.java:425)

at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223)

at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74)

at org.eclipse.jetty.server.ServerConnector.open(ServerConnector.java:321)

at org.eclipse.jetty.server.AbstractNetworkConnector.doStart(AbstractNetworkConnector.java:80)

at org.eclipse.jetty.server.ServerConnector.doStart(ServerConnector.java:236)

at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)

at org.eclipse.jetty.server.Server.doStart(Server.java:366)

at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)

at org.apache.kafka.connect.runtime.rest.RestServer.start(RestServer.java:145)

at org.apache.kafka.connect.runtime.Connect.start(Connect.java:54)

at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:81)

[2017-05-09 13:20:00,872] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:99)

org.apache.kafka.connect.errors.ConnectException: Unable to start REST server

at org.apache.kafka.connect.runtime.rest.RestServer.start(RestServer.java:147)

at org.apache.kafka.connect.runtime.Connect.start(Connect.java:54)

at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:81)

Caused by: java.net.BindException: Address already in use

at sun.nio.ch.Net.bind0(Native Method)

at sun.nio.ch.Net.bind(Net.java:433)

at sun.nio.ch.Net.bind(Net.java:425)

at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223)

at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74)

at org.eclipse.jetty.server.ServerConnector.open(ServerConnector.java:321)

at org.eclipse.jetty.server.AbstractNetworkConnector.doStart(AbstractNetworkConnector.java:80)

at org.eclipse.jetty.server.ServerConnector.doStart(ServerConnector.java:236)

at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)

at org.eclipse.jetty.server.Server.doStart(Server.java:366)

at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)

at org.apache.kafka.connect.runtime.rest.RestServer.start(RestServer.java:145)

... 2 more

[2017-05-09 13:20:00,872] INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:66)

[2017-05-09 13:20:00,872] INFO Stopping REST server (org.apache.kafka.connect.runtime.rest.RestServer:154)

[2017-05-09 13:20:00,876] INFO Stopped ServerConnector@3b4ef7{HTTP/1.1}{0.0.0.0:8083} (org.eclipse.jetty.server.ServerConnector:306)

[2017-05-09 13:20:00,917] INFO Stopped o.e.j.s.ServletContextHandler@46292372{/,null,UNAVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:865)

[2017-05-09 13:20:00,922] INFO REST server stopped (org.apache.kafka.connect.runtime.rest.RestServer:165)

[2017-05-09 13:20:00,922] INFO Herder stopping (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:77)

[2017-05-09 13:20:00,923] INFO Worker stopping (org.apache.kafka.connect.runtime.Worker:131)

[2017-05-09 13:20:00,923] INFO Stopped FileOffsetBackingStore (org.apache.kafka.connect.storage.FileOffsetBackingStore:68)

[2017-05-09 13:20:00,923] INFO Worker stopped (org.apache.kafka.connect.runtime.Worker:151)

[2017-05-09 13:20:32,437] INFO Reflections took 34184 ms to scan 560 urls, producing 12993 keys and 85595 values  (org.reflections.Reflections:229)

[2017-05-09 13:20:33,268] INFO Herder stopped (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:87)

[2017-05-09 13:20:33,268] INFO Kafka Connect stopped (org.apache.kafka.connect.runtime.Connect:71)

[Gwen Shapira]

Hi,

The first command you ran was:

bin/connect-standalone standalone.properties new-custom-connector.properties

and you got:

Exception in thread "main" java.io.FileNotFoundException: standalone.properties (No such file or directory)

This indicates that the file standalone.properties does not exist in the current directory you are in. Either make sure the file is in current directory or give the correct path information.

The second command you ran was:

 ./bin/connect-standalone ./etc/schema-registry/connect-avro-standalone.properties ./etc/kafka-connect-jdbc/mysql-source.properties

and the error was:

[2017-05-09 13:20:00,834] WARN FAILED ServerConnector@3b4ef7{HTTP/1.1}{0.0.0.0:8083}: java.net.BindException: Address already in use (org.eclipse.jetty.util.component.AbstractLifeCycle:212)

This indicates that either you already have another Connect process running, or you have something else that uses port 8083. Either stop the running process that uses the port, or configure this connect worker to start in a different port (by editing ./etc/schema-registry/connect-avro-standalone.properties).

Good luck!

Gwen

--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To post to this group, send email to confluent-platform@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/a4a38fe1-c5a7-4edd-9ed5-9e4aa08778d8%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

--

Gwen Shapira

Product Manager | Confluent

650.450.2760 | @gwenshap

Follow us: Twitter | blog

[Gwen Shapira]

You are 100% correct that you have a network issue and Connect can't connect to the MySQL database.

Your JDBC URI is: jdbc:mysql://130.113.130.194:8006/Conal_TEST?user=dev&password=Factory1

This is unusual - MySQL is usually on port 3306. Can you double check you have this right?

Gwen

On Tue, May 9, 2017 at 2:06 PM Conal Nicholls <conalni...@gmail.com> wrote:

Hi, Thanks for the advice above, I'm now trying to connect to my network sql database and I think my connections timing out but I'm not sure why.
If i visit the url in my web browser I can connect to the phpmyadmin associated with mysql database . Can you confirm everything on my kafka end of things is correct?

properties file : 

name=test-mysql-jdbc

connector.class=io.confluent.connect.jdbc.JdbcSourceConnector

tasks.max=1

connection.url=jdbc:mysql://130.113.130.194:8006/Conal_TEST?user=dev&password=Factory1

mode=timestamp+incrementing

incrementing.column.name=id

timestamp.column.name=modified

topic.prefix=test_jdbc_

conal@conal-VirtualBox:~/Desktop/confluent-3.2.1$ ./bin/connect-standalone ./etc/schema-registry/connect-avro-standalone.properties ./etc/kafka-connect-jdbc/mysql-source.properties 

SLF4J: Class path contains multiple SLF4J bindings.

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka-serde-tools/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka-connect-elasticsearch/slf4j-simple-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka-connect-hdfs/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka-connect-s3/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka-connect-storage-common/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/conal/Desktop/confluent-3.2.1/share/java/kafka/slf4j-log4j12-1.7.21.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.

SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]

[2017-05-09 16:43:16,140] INFO StandaloneConfig values: 

access.control.allow.methods = 

access.control.allow.origin = 

bootstrap.servers = [localhost:9092]

internal.key.converter = class org.apache.kafka.connect.json.JsonConverter

internal.value.converter = class org.apache.kafka.connect.json.JsonConverter

key.converter = class io.confluent.connect.avro.AvroConverter

offset.flush.interval.ms = 60000

offset.flush.timeout.ms = 5000

offset.storage.file.filename = /tmp/connect.offsets

rest.advertised.host.name = null

rest.advertised.port = null

rest.host.name = null

rest.port = 8083

task.shutdown.graceful.timeout.ms = 5000

value.converter = class io.confluent.connect.avro.AvroConverter

 (org.apache.kafka.connect.runtime.standalone.StandaloneConfig:180)

[2017-05-09 16:43:16,403] INFO Logging initialized @4359ms (org.eclipse.jetty.util.log:186)

[2017-05-09 16:43:16,912] INFO AvroConverterConfig values: 

schema.registry.url = [http://localhost:8081]

max.schemas.per.subject = 1000

 (io.confluent.connect.avro.AvroConverterConfig:169)

[2017-05-09 16:43:17,113] INFO AvroDataConfig values: 

schemas.cache.config = 1000

enhanced.avro.schema.support = false

connect.meta.data = true

 (io.confluent.connect.avro.AvroDataConfig:169)

[2017-05-09 16:43:17,129] INFO AvroConverterConfig values: 

schema.registry.url = [http://localhost:8081]

max.schemas.per.subject = 1000

 (io.confluent.connect.avro.AvroConverterConfig:169)

[2017-05-09 16:43:17,129] INFO AvroDataConfig values: 

schemas.cache.config = 1000

enhanced.avro.schema.support = false

connect.meta.data = true

 (io.confluent.connect.avro.AvroDataConfig:169)

[2017-05-09 16:43:17,157] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:50)

[2017-05-09 16:43:17,157] INFO Herder starting (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:71)

[2017-05-09 16:43:17,158] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:119)

[2017-05-09 16:43:17,159] INFO Starting FileOffsetBackingStore with file /tmp/connect.offsets (org.apache.kafka.connect.storage.FileOffsetBackingStore:60)

[2017-05-09 16:43:17,204] INFO Worker started (org.apache.kafka.connect.runtime.Worker:124)

[2017-05-09 16:43:17,209] INFO Herder started (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:73)

[2017-05-09 16:43:17,209] INFO Starting REST server (org.apache.kafka.connect.runtime.rest.RestServer:98)

[2017-05-09 16:43:17,645] INFO jetty-9.2.15.v20160210 (org.eclipse.jetty.server.Server:327)

May 09, 2017 4:43:20 PM org.glassfish.jersey.internal.Errors logErrors

WARNING: The following warnings have been detected: WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.

WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.

WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation.

WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation.

[2017-05-09 16:43:20,202] INFO Started o.e.j.s.ServletContextHandler@6c44052e{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:744)

[2017-05-09 16:43:20,330] INFO Started ServerConnector@34b90a53{HTTP/1.1}{0.0.0.0:8083} (org.eclipse.jetty.server.ServerConnector:266)

[2017-05-09 16:43:20,331] INFO Started @8290ms (org.eclipse.jetty.server.Server:379)

[2017-05-09 16:43:20,332] INFO REST server listening at http://127.0.1.1:8083/, advertising URL http://127.0.1.1:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:150)

[2017-05-09 16:43:20,332] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:56)

[2017-05-09 16:43:41,929] INFO Reflections took 24538 ms to scan 561 urls, producing 13097 keys and 85890 values  (org.reflections.Reflections:229)

[2017-05-09 16:54:25,025] ERROR Failed to create job for ./etc/kafka-connect-jdbc/mysql-source.properties (org.apache.kafka.connect.cli.ConnectStandalone:88)

[2017-05-09 16:54:25,027] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:99)

java.util.concurrent.ExecutionException: org.apache.kafka.connect.runtime.rest.errors.BadRequestException: Connector configuration is invalid and contains the following 2 error(s):

Invalid value com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure

The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server. for configuration Couldn't open connection to jdbc:mysql://130.113.130.194:8006/Conal_TEST?user=dev&password=Factory1

Invalid value com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure

The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server. for configuration Couldn't open connection to jdbc:mysql://130.113.130.194:8006/Conal_TEST?user=dev&password=Factory1

You can also find the above list of errors at the endpoint `/{connectorType}/config/validate`

at org.apache.kafka.connect.util.ConvertingFutureCallback.result(ConvertingFutureCallback.java:80)

at org.apache.kafka.connect.util.ConvertingFutureCallback.get(ConvertingFutureCallback.java:67)

at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:96)

Caused by: org.apache.kafka.connect.runtime.rest.errors.BadRequestException: Connector configuration is invalid and contains the following 2 error(s):

Invalid value com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure

The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server. for configuration Couldn't open connection to jdbc:mysql://130.113.130.194:8006/Conal_TEST?user=dev&password=Factory1

Invalid value com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure

The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server. for configuration Couldn't open connection to jdbc:mysql://130.113.130.194:8006/Conal_TEST?user=dev&password=Factory1

You can also find the above list of errors at the endpoint `/{connectorType}/config/validate`

at org.apache.kafka.connect.runtime.AbstractHerder.maybeAddConfigErrors(AbstractHerder.java:365)

at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.putConnectorConfig(StandaloneHerder.java:158)

at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:93)

[2017-05-09 16:54:25,040] INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:66)

[2017-05-09 16:54:25,041] INFO Stopping REST server (org.apache.kafka.connect.runtime.rest.RestServer:154)

[2017-05-09 16:54:25,180] INFO Stopped ServerConnector@34b90a53{HTTP/1.1}{0.0.0.0:8083} (org.eclipse.jetty.server.ServerConnector:306)

[2017-05-09 16:54:25,227] INFO Stopped o.e.j.s.ServletContextHandler@6c44052e{/,null,UNAVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:865)

[2017-05-09 16:54:25,233] INFO REST server stopped (org.apache.kafka.connect.runtime.rest.RestServer:165)

[2017-05-09 16:54:25,233] INFO Herder stopping (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:77)

[2017-05-09 16:54:25,233] INFO Worker stopping (org.apache.kafka.connect.runtime.Worker:131)

[2017-05-09 16:54:25,233] INFO Stopped FileOffsetBackingStore (org.apache.kafka.connect.storage.FileOffsetBackingStore:68)

[2017-05-09 16:54:25,234] INFO Worker stopped (org.apache.kafka.connect.runtime.Worker:151)

[2017-05-09 16:54:25,234] INFO Herder stopped (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:87)

[2017-05-09 16:54:25,234] INFO Kafka Connect stopped (org.apache.kafka.connect.runtime.Connect:71)

conal@conal-VirtualBox:~/Desktop/confluent-3.2.1$

--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.

To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/b6b816e9-a4e1-4db1-99ee-04aca04e5566%40googlegroups.com.