Соединитель InfluxDB неверный формат отметки времени - PullRequest
0 голосов
/ 01 апреля 2019

У меня на Kafka есть следующий разъем InfluxDB:

{
  "connector.class": "com.datamountaineer.streamreactor.connect.influx.InfluxSinkConnector",
  "connect.influx.db": "kafka",
  "topics": "TestJson",
  "tasks.max": "1",
  "connect.influx.kcql": "INSERT INTO TestJsonStation SELECT * FROM TestJson WITHTIMESTAMP TimeStamp",
  "connect.influx.url": "http://influxdb:8086",
  "value.converter.schema.registry.url": "http://localhost:8081",
  "value.converter": "io.confluent.connect.avro.AvroConverter",
  "key.converter": "io.confluent.connect.avro.AvroConverter",
  "key.converter.schema.registry.url": "http://localhost:8081"
}

Я получаю это исключение из-за того, что отметка времени в сообщении mqtt имеет неправильный формат.

java.lang.IllegalArgumentException: 4/1/2019 10:05:31 AM is not a valid format for timestamp, expected 'yyyy-MM-DDTHH:mm:ss.SSSZ'

Есть ли способ это исправить? (У меня нет контроля над библиотекой, создающей сообщение)

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...