juhoautio

package com.quantifind.kafka.reporter.influxdb
import java.util.concurrent.TimeUnit

import com.quantifind.kafka.OffsetGetter
import com.quantifind.kafka.offsetapp.OffsetInfoReporter
import com.quantifind.kafka.reporter.influxdb.InfluxDBOffsetInfoReporter.pluginArgsToMap
import org.influxdb.dto.{BatchPoints, Point}
import org.influxdb.{InfluxDB, InfluxDBFactory}

class InfluxDBOffsetInfoReporter(pluginsArgs: String) extends OffsetInfoReporter {