Package org.apache.storm.kafka.spout
Class KafkaSpoutMessageId
java.lang.Object
org.apache.storm.kafka.spout.KafkaSpoutMessageId
- All Implemented Interfaces:
- Serializable
- See Also:
- 
Constructor SummaryConstructorsConstructorDescriptionKafkaSpoutMessageId(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
- 
Constructor Details- 
KafkaSpoutMessageIdpublic KafkaSpoutMessageId(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> consumerRecord) 
- 
KafkaSpoutMessageIdpublic KafkaSpoutMessageId(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> consumerRecord, boolean nullTuple) 
- 
KafkaSpoutMessageIdpublic KafkaSpoutMessageId(org.apache.kafka.common.TopicPartition topicPart, long offset) 
- 
KafkaSpoutMessageIdpublic KafkaSpoutMessageId(org.apache.kafka.common.TopicPartition topicPart, long offset, boolean nullTuple) Creates a new KafkaSpoutMessageId.- Parameters:
- topicPart- The topic partition this message belongs to
- offset- The offset of this message
- nullTuple- True if this message is being skipped as a null tuple
 
 
- 
- 
Method Details- 
partitionpublic int partition()
- 
topic
- 
offsetpublic long offset()
- 
numFailspublic int numFails()
- 
incrementNumFailspublic void incrementNumFails()
- 
getTopicPartitionpublic org.apache.kafka.common.TopicPartition getTopicPartition()
- 
isNullTuplepublic boolean isNullTuple()
- 
setNullTuplepublic void setNullTuple(boolean nullTuple) 
- 
toString
- 
equals
- 
hashCodepublic int hashCode()
 
-