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

Class KafkaMsg

java.lang.Object

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

public class KafkaMsg
extends Object

Created by IntelliJ IDEA. User: hackerwin7 Date: 2015/12/08 Time: 3:06 PM Desc:

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaMsg.KafkaMsgBuilder builder class

Method Summary

Modifier and Type	Method and Description
static KafkaMsg.KafkaMsgBuilder	createBuilder() create builder
String	getKey()
long	getNextOffset()
long	getOffset()
int	getParititon()
String	getTopic()
byte[]	getVal()

Methods inherited from class java.lang.Object

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

Method Detail

createBuilder

public static KafkaMsg.KafkaMsgBuilder createBuilder()

create builder

Returns:

builder

getKey

public String getKey()

getVal

public byte[] getVal()

getOffset

public long getOffset()

getNextOffset

public long getNextOffset()

getTopic

public String getTopic()

getParititon

public int getParititon()