kafka/ru.sydis.kafka/DataProducer

DataProducer

class DataProducer(host: String, top: String = "pure_data")

Constructors

Link copied to clipboard
constructor(host: String, top: String = "pure_data")

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
fun send(id: ByteArray, inData: ProtoMessage, topicForWrite: String)
fun send(dest: ProtoManId, inData: ProtoMessage, timestamp: Long = -1)
Link copied to clipboard
fun stop()