Advertisement
Guest User

Untitled

a guest
Aug 9th, 2016
135
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.67 KB | None | 0 0
  1. [2016-08-09 21:54:15,331] INFO JdbcSourceConnectorConfig values:
  2. timestamp.column.name =
  3. incrementing.column.name =
  4. validate.non.null = true
  5. query =
  6. batch.max.rows = 100
  7. timestamp.delay.interval.ms = 0
  8. table.blacklist = []
  9. table.poll.interval.ms = 60000
  10. table.whitelist = [[iatest]]
  11. mode = bulk
  12. topic.prefix = test-td-jdbc-
  13. poll.interval.ms = 5000
  14. connection.url = jdbc:teradata://db.com/charset=UTF8,DBS_PORT=1025,DATABASE=db_name,USER=1234,PASSWORD=1234
  15. (io.confluent.connect.jdbc.JdbcSourceConnectorConfig:178)
  16.  
  17. [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)
  18. [2016-08-09 21:55:09,351] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:100)
  19. java.lang.IllegalArgumentException: Number of groups must be positive.
  20. at org.apache.kafka.connect.util.ConnectorUtils.groupPartitions(ConnectorUtils.java:45)
  21. at io.confluent.connect.jdbc.JdbcSourceConnector.taskConfigs(JdbcSourceConnector.java:121)
  22. at org.apache.kafka.connect.runtime.Worker.connectorTaskConfigs(Worker.java:267)
  23. at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.recomputeTaskConfigs(StandaloneHerder.java:265)
  24. at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.updateConnectorTasks(StandaloneHerder.java:302)
  25. at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.putConnectorConfig(StandaloneHerder.java:165)
  26. at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:94)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement