com.github.hackerwin7.jlib.utils.drivers.kafka.data

Class KafkaMsg.KafkaMsgBuilder

java.lang.Object

com.github.hackerwin7.jlib.utils.drivers.kafka.data.KafkaMsg.KafkaMsgBuilder

Enclosing class:

KafkaMsg

public static class KafkaMsg.KafkaMsgBuilder
extends Object

builder class

Method Summary

Modifier and Type	Method and Description
KafkaMsg	build()
KafkaMsg.KafkaMsgBuilder	key(String key)
KafkaMsg.KafkaMsgBuilder	nextOffset(long nextOffset)
KafkaMsg.KafkaMsgBuilder	offset(long offset)
KafkaMsg.KafkaMsgBuilder	partition(int partition)
KafkaMsg.KafkaMsgBuilder	topic(String topic)
KafkaMsg.KafkaMsgBuilder	val(byte[] val)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

key

public KafkaMsg.KafkaMsgBuilder key(String key)

val

public KafkaMsg.KafkaMsgBuilder val(byte[] val)

offset

public KafkaMsg.KafkaMsgBuilder offset(long offset)

nextOffset

public KafkaMsg.KafkaMsgBuilder nextOffset(long nextOffset)

topic

public KafkaMsg.KafkaMsgBuilder topic(String topic)

partition

public KafkaMsg.KafkaMsgBuilder partition(int partition)

build

public KafkaMsg build()