io.druid.firehose.kafka

Class KafkaSimpleConsumer.BytesMessageWithOffset

java.lang.Object

io.druid.firehose.kafka.KafkaSimpleConsumer.BytesMessageWithOffset

Enclosing class:

KafkaSimpleConsumer

public static class KafkaSimpleConsumer.BytesMessageWithOffset
extends Object

Constructor Summary

Constructors

Constructor and Description
BytesMessageWithOffset(byte[] msg, long offset, int partition)

Method Summary

Modifier and Type	Method and Description
int	getPartition()
byte[]	message()
long	offset()

Methods inherited from class java.lang.Object

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

Constructor Detail

BytesMessageWithOffset

public BytesMessageWithOffset(byte[] msg,
                              long offset,
                              int partition)

Method Detail

getPartition

public int getPartition()

message

public byte[] message()

offset

public long offset()