kafka/ru.sydis.kafka/DataConsumer

DataConsumer

class DataConsumer(host: String, topic: String = "", groupe: String = Config.getPmonTopicName())

Constructors

constructor(host: String, topic: String = "", groupe: String = Config.getPmonTopicName())

Properties

var lastValue: Map<String, String>

var state: States

Functions

fun doStop()

Stop subscribe() after called

fun stop()

fun subscribe(msgReceived: (ConsumerRecord<ByteArray, ProtoMessage>) -> Unit)

Subscription on new messages in topic