クラス KafkaMessageSource.KafkaAckInfoImpl

メソッドの詳細

• getConsumerMonitor

  public ObjectSE getConsumerMonitor()

  次で指定:

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

• getGroupId

  public @Nullable StringSE getGroupId()

  次で指定:

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

• getConsumer

  public @Nullable 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