com.github.hekonsek.rxjava.connector.kafka

Class KafkaHeaders

java.lang.Object

com.github.hekonsek.rxjava.connector.kafka.KafkaHeaders

public final class KafkaHeaders
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	OFFSET
static String	PARTITION

Method Summary

Modifier and Type	Method and Description
static long	offset(com.github.hekonsek.rxjava.event.Event event)
static int	partition(com.github.hekonsek.rxjava.event.Event event)

Methods inherited from class java.lang.Object

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

Field Detail

OFFSET

public static final String OFFSET

See Also:

Constant Field Values

PARTITION

public static final String PARTITION

See Also:

Constant Field Values

Method Detail

offset

public static long offset(com.github.hekonsek.rxjava.event.Event event)

partition

public static int partition(com.github.hekonsek.rxjava.event.Event event)