Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- [2016-08-09 21:54:15,331] INFO JdbcSourceConnectorConfig values:
- timestamp.column.name =
- incrementing.column.name =
- validate.non.null = true
- query =
- batch.max.rows = 100
- timestamp.delay.interval.ms = 0
- table.blacklist = []
- table.poll.interval.ms = 60000
- table.whitelist = [[iatest]]
- mode = bulk
- topic.prefix = test-td-jdbc-
- poll.interval.ms = 5000
- connection.url = jdbc:teradata://db.com/charset=UTF8,DBS_PORT=1025,DATABASE=db_name,USER=1234,PASSWORD=1234
- (io.confluent.connect.jdbc.JdbcSourceConnectorConfig:178)
- [2016-08-09 21:54:29,955] INFO Reflections took 15272 ms to scan 262 urls, producing 12077 keys and 79285 values (org.reflections.Reflections:229)
- [2016-08-09 21:55:09,351] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:100)
- java.lang.IllegalArgumentException: Number of groups must be positive.
- at org.apache.kafka.connect.util.ConnectorUtils.groupPartitions(ConnectorUtils.java:45)
- at io.confluent.connect.jdbc.JdbcSourceConnector.taskConfigs(JdbcSourceConnector.java:121)
- at org.apache.kafka.connect.runtime.Worker.connectorTaskConfigs(Worker.java:267)
- 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)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement