Class KafkaSpoutMessageId

    • 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 to
        offset - The offset of this message
        nullTuple - 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)
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object