TcpSink

constructor(host: String, port: Int, batchSize: Int = 100, flushIntervalMs: Long = 5000, connectionTimeoutMs: Int = 5000)(source)