Uses of Class
com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg

Packages that use KafkaMsg

Package	Description
com.github.hackerwin7.jlib.utils.drivers.kafka.consumer
com.github.hackerwin7.jlib.utils.drivers.kafka.data
com.github.hackerwin7.jlib.utils.drivers.kafka.producer

Uses of KafkaMsg in com.github.hackerwin7.jlib.utils.drivers.kafka.consumer

Methods in com.github.hackerwin7.jlib.utils.drivers.kafka.consumer that return KafkaMsg

Modifier and Type	Method and Description
KafkaMsg	KafkaHighConsumer.consume() consume a msg
KafkaMsg	KafkaSimpleConsumer.consume() consume message

Methods in com.github.hackerwin7.jlib.utils.drivers.kafka.consumer that return types with arguments of type KafkaMsg

Modifier and Type	Method and Description
List<KafkaMsg>	KafkaHighConsumer.consume(int num, long timeout) batch consume kafka

Uses of KafkaMsg in com.github.hackerwin7.jlib.utils.drivers.kafka.data

Methods in com.github.hackerwin7.jlib.utils.drivers.kafka.data that return KafkaMsg

Modifier and Type	Method and Description
KafkaMsg	KafkaMsg.KafkaMsgBuilder.build()

Uses of KafkaMsg in com.github.hackerwin7.jlib.utils.drivers.kafka.producer

Methods in com.github.hackerwin7.jlib.utils.drivers.kafka.producer with parameters of type KafkaMsg

Modifier and Type	Method and Description
void	KafkaProducer.sendKafkaMsg(KafkaMsg msg) sendKafkaMsg single
static kafka.producer.KeyedMessage<String,byte[]>	KafkaProducer.toKeyedMessage(KafkaMsg msg) convert to keyedmessage

Method parameters in com.github.hackerwin7.jlib.utils.drivers.kafka.producer with type arguments of type KafkaMsg

Modifier and Type	Method and Description
void	KafkaProducer.sendKafkaMsg(List<KafkaMsg> msgs) sendKafkaMsg batch
static List<kafka.producer.KeyedMessage<String,byte[]>>	KafkaProducer.toKeyedMessage(List<KafkaMsg> msgs) convert to batch keyedmessages