Package org.apache.storm.kafka.spout
Class KafkaSpoutMessageId
java.lang.Object
org.apache.storm.kafka.spout.KafkaSpoutMessageId
- All Implemented Interfaces:
Serializable
- See Also:
-
Constructor Summary
ConstructorDescriptionKafkaSpoutMessageId
(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
-
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 Details
-
partition
public int partition() -
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) -
toString
-
equals
-
hashCode
public int hashCode()
-