クラス KafkaMessageSource.KafkaAckInfoImpl

方法の詳細

• getConsumerMonitor

  public ObjectSE getConsumerMonitor()

  次で指定:

  インターフェース KafkaMessageSource.KafkaAckInfo<K,V> 内の getConsumerMonitor 

• getGroupId

  public StringSE getGroupId()

  次で指定:

  インターフェース KafkaMessageSource.KafkaAckInfo<K,V> 内の getGroupId 

• getConsumer

  public org.apache.kafka.clients.consumer.Consumer<K,V> getConsumer()

  次で指定:

  インターフェース KafkaMessageSource.KafkaAckInfo<K,V> 内の getConsumer 

• getRecord

  public org.apache.kafka.clients.consumer.ConsumerRecord<K,V> getRecord()

  次で指定:

  インターフェース KafkaMessageSource.KafkaAckInfo<K,V> 内の getRecord 

• getTopicPartition

  public org.apache.kafka.common.TopicPartition getTopicPartition()

  次で指定:

  インターフェース KafkaMessageSource.KafkaAckInfo<K,V> 内の getTopicPartition 

• getOffsets

  public MapSE<org.apache.kafka.common.TopicPartition,SetSE<KafkaMessageSource.KafkaAckInfo<K,V>>> getOffsets()

  次で指定:

  インターフェース KafkaMessageSource.KafkaAckInfo<K,V> 内の getOffsets 

• isRolledBack

  public boolean isRolledBack()

  次で指定:

  インターフェース KafkaMessageSource.KafkaAckInfo<K,V> 内の isRolledBack 

• setRolledBack

  public void setRolledBack(boolean rolledBack)

  次で指定:

  インターフェース KafkaMessageSource.KafkaAckInfo<K,V> 内の setRolledBack 

• isAckDeferred

  public boolean isAckDeferred()

  次で指定:

  インターフェース KafkaMessageSource.KafkaAckInfo<K,V> 内の isAckDeferred 

• setAckDeferred

  public void setAckDeferred(boolean ackDeferred)

  次で指定:

  インターフェース KafkaMessageSource.KafkaAckInfo<K,V> 内の setAckDeferred 

• compareTo

  public int compareTo(KafkaMessageSource.KafkaAckInfo<K,V> other)

  次で指定:

  インターフェース ComparableSE<KafkaMessageSource.KafkaAckInfo<K,V>> 内の compareToSE 

• toString

  public StringSE toString()

  オーバーライド:

  クラス ObjectSE の toString