kafka-connectors-tests icon indicating copy to clipboard operation
kafka-connectors-tests copied to clipboard

Published 20 hours ago • verified publisher icon lensesio

Additional InfluxDB test for <tag> support

Open Antwnis opened this issue 8 years ago • 0 comments

In latest ( 0.2.4 latest ) on master InfluxDB connector changed with

  • Added InfluxDB tag support. KCQL: INSERT INTO targetDimension SELECT * FROM influx-topic WITHTIMESTAMP sys_time() WITHTAG(field1, CONSTANT_KEY1=CONSTANT_VALUE1, field2,CONSTANT_KEY2=CONSTANT_VALUE1)

  • Added InfluxDb consistency level. Default is ALL. Use connect.influx.consistency.level to set it to ONE/QUORUM/ALL/ANY

  • InfluxDb connect.influx.sink.route.query was renamed to connect.influx.sink.kcql

Antwnis avatar Jan 21 '17 11:01 Antwnis