Even after specifying all the required properties, the connector fails to start with the following exception
[2016-05-25 15:20:29,947] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:58)
[2016-05-25 15:20:29,948] INFO ConnectorConfig values:
connector.class = org.aravind.oss.kafka.connector.JenkinsSourceConnector
tasks.max = 1
name = kafka-jenkins-source-connector
(org.apache.kafka.connect.runtime.ConnectorConfig:178)
[2016-05-25 15:20:29,950] INFO Creating connector kafka-jenkins-source-connector of type org.aravind.oss.kafka.connector.JenkinsSourceConnector (org.apache.kafka.connect.runtime.Worker:168)
[2016-05-25 15:20:29,951] INFO Instantiated connector kafka-jenkins-source-connector with version 0.5.0 of type org.aravind.oss.kafka.connector.JenkinsSourceConnector (org.apache.kafka.connect.runtime.Worker:176)
[2016-05-25 15:20:29,953] INFO JenkinsSourceConfig values:
jenkins.jobs.resource.path = /api/json
jenkins.username =
jenkins.password.or.api.token =
topic = jenkins.connector.topic
jenkins.base.url = http://acspplc9a021.app.c9.equifax.com:8080/jenkins/api/json
(org.aravind.oss.kafka.connector.JenkinsSourceConfig:178)
[2016-05-25 15:20:29,966] INFO Finished creating connector kafka-jenkins-source-connector (org.apache.kafka.connect.runtime.Worker:181)
[2016-05-25 15:20:29,966] INFO SourceConnectorConfig values:
connector.class = org.aravind.oss.kafka.connector.JenkinsSourceConnector
tasks.max = 1
name = kafka-jenkins-source-connector
(org.apache.kafka.connect.runtime.SourceConnectorConfig:178)
[2016-05-25 15:20:29,967] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:100)
java.lang.NullPointerException
at org.apache.kafka.connect.runtime.Worker.connectorTaskConfigs(Worker.java:266)
at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.recomputeTaskConfigs(StandaloneHerder.java:265)
at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.updateConnectorTasks(StandaloneHerder.java:302)
at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.putConnectorConfig(StandaloneHerder.java:165)
at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:94)
[2016-05-25 15:20:29,968] INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:68)
[2016-05-25 15:20:29,968] INFO Stopping REST server (org.apache.kafka.connect.runtime.rest.RestServer:154)
[2016-05-25 15:20:29,974] INFO Stopped ServerConnector@19fb8826{HTTP/1.1}{0.0.0.0:8083} (org.eclipse.jetty.server.ServerConnector:306)
[2016-05-25 15:20:29,979] INFO Stopped o.e.j.s.ServletContextHandler@47db5fa5{/,null,UNAVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:865)
[2016-05-25 15:20:29,980] INFO REST server stopped (org.apache.kafka.connect.runtime.rest.RestServer:165)
[2016-05-25 15:20:29,980] INFO Herder stopping (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:77)
[2016-05-25 15:20:29,980] INFO Stopping connector kafka-jenkins-source-connector (org.apache.kafka.connect.runtime.Worker:278)
[2016-05-25 15:20:29,980] INFO Stopped connector kafka-jenkins-source-connector (org.apache.kafka.connect.runtime.Worker:287)
[2016-05-25 15:20:29,981] INFO Worker stopping (org.apache.kafka.connect.runtime.Worker:128)
[2016-05-25 15:20:29,981] WARN Shutting down tasks [] uncleanly; herder should have shut down tasks before the Worker is stopped. (org.apache.kafka.connect.runtime.Worker:141)
[2016-05-25 15:20:29,981] INFO Stopped FileOffsetBackingStore (org.apache.kafka.connect.storage.FileOffsetBackingStore:68)
[2016-05-25 15:20:29,981] INFO Worker stopped (org.apache.kafka.connect.runtime.Worker:151)
[2016-05-25 15:20:34,481] INFO Reflections took 5083 ms to scan 260 urls, producing 11974 keys and 78905 values (org.reflections.Reflections:229)
[2016-05-25 15:20:34,491] INFO Herder stopped (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:91)
[2016-05-25 15:20:34,491] INFO Kafka Connect stopped (org.apache.kafka.connect.runtime.Connect:73)
Even after specifying all the required properties, the connector fails to start with the following exception