Package org.apache.storm.kafka.spout
Class KafkaSpoutMessageId
- java.lang.Object
-
- org.apache.storm.kafka.spout.KafkaSpoutMessageId
-
- All Implemented Interfaces:
Serializable
public class KafkaSpoutMessageId extends Object implements Serializable
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description KafkaSpoutMessageId(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord)KafkaSpoutMessageId(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord, boolean nullTuple)KafkaSpoutMessageId(org.apache.kafka.common.TopicPartition topicPart, long offset)KafkaSpoutMessageId(org.apache.kafka.common.TopicPartition topicPart, long offset, boolean nullTuple)Creates a new KafkaSpoutMessageId.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object o)org.apache.kafka.common.TopicPartitiongetTopicPartition()inthashCode()voidincrementNumFails()booleanisNullTuple()intnumFails()longoffset()intpartition()voidsetNullTuple(boolean nullTuple)Stringtopic()StringtoString()
-
-
-
Constructor Detail
-
KafkaSpoutMessageId
public KafkaSpoutMessageId(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord)
-
KafkaSpoutMessageId
public KafkaSpoutMessageId(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord, boolean nullTuple)
-
KafkaSpoutMessageId
public KafkaSpoutMessageId(org.apache.kafka.common.TopicPartition topicPart, long offset)
-
KafkaSpoutMessageId
public KafkaSpoutMessageId(org.apache.kafka.common.TopicPartition topicPart, long offset, boolean nullTuple)Creates a new KafkaSpoutMessageId.- Parameters:
topicPart- The topic partition this message belongs tooffset- The offset of this messagenullTuple- True if this message is being skipped as a null tuple
-
-
Method Detail
-
partition
public int partition()
-
topic
public String topic()
-
offset
public long offset()
-
numFails
public int numFails()
-
incrementNumFails
public void incrementNumFails()
-
getTopicPartition
public org.apache.kafka.common.TopicPartition getTopicPartition()
-
isNullTuple
public boolean isNullTuple()
-
setNullTuple
public void setNullTuple(boolean nullTuple)
-
-