daily pastebin goal
53%
SHARE
TWEET

Untitled

a guest Sep 4th, 2018 73 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  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. }
RAW Paste Data
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy. OK, I Understand
 
Top