Guest User

Untitled

a guest
Sep 4th, 2018
119
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 3.13 KB | None | 0 0
  1. [2018-09-04 14:48:03,324] WARN Ignoring record due to SQL error: (io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier)
  2. org.postgresql.util.PSQLException: Bad value for type byte : 183.9382
  3. at org.postgresql.jdbc2.AbstractJdbc2ResultSet.getByte(AbstractJdbc2ResultSet.java:2093)
  4. at io.confluent.connect.jdbc.dialect.GenericDatabaseDialect.lambda$columnConverterFor$18(GenericDatabaseDialect.java:1166)
  5. at io.confluent.connect.jdbc.source.SchemaMapping$FieldSetter.setField(SchemaMapping.java:160)
  6. at io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier.extractRecord(TimestampIncrementingTableQuerier.java:176)
  7. at io.confluent.connect.jdbc.source.JdbcSourceTask.poll(JdbcSourceTask.java:297)
  8. at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:244)
  9. at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:220)
  10. at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175)
  11. at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219)
  12. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  13. at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  14. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
  15. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
  16. at java.lang.Thread.run(Thread.java:748)
  17.  
  18. {
  19. "name": "jdbc_source_sales.salesorderdetail",
  20. "config": {
  21. "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
  22. "tasks.max": "1",
  23. "topics": "sales.salesorderdetail",
  24. "connection.url": "jdbc:postgresql://172.18.0.1/adventureworks?user=postgres&password=postgres",
  25. "mode": "timestamp+incrementing",
  26. "timestamp.column.name": "modifieddate",
  27. "incrementing.column.name": "salesorderid",
  28. "topic.prefix": "jdbc_source_sales_",
  29. "table.whitelist": "sales.salesorderdetail",
  30. "transforms": "CastUnitPrice, InsertKey, ExtractId, CastLong, AddNamespace",
  31. "transforms.InsertKey.type": "org.apache.kafka.connect.transforms.ValueToKey",
  32. "transforms.InsertKey.fields": "salesorderid",
  33. "transforms.ExtractId.type": "org.apache.kafka.connect.transforms.ExtractField$Key",
  34. "transforms.ExtractId.field": "salesorderid",
  35. "transforms.CastLong.type": "org.apache.kafka.connect.transforms.Cast$Key",
  36. "transforms.CastLong.spec": "int64",
  37. "transforms.AddNamespace.type": "de.smava.kafka.connect.transforms.Namespacefy",
  38. "transforms.AddNamespace.record.namespace": "com.company.data.vault20",
  39. "transforms.CastUnitPrice.type": "org.apache.kafka.connect.transforms.Cast$Value",
  40. "transforms.CastUnitPrice.spec": "unitprice:float64",
  41. "key.converter": "org.apache.kafka.connect.storage.StringConverter",
  42. "key.converter.schemas.enable": "false",
  43. "value.converter": "io.confluent.connect.avro.AvroConverter",
  44. "value.converter.schemas.enable": "true",
  45. "value.converter.schema.registry.url": "http://schema-registry:8081",
  46. "numeric.mapping": "best_fit"
  47.  
  48. }
  49. }
Add Comment
Please, Sign In to add comment