メソッドの詳細

• getConsumerMonitor

  ObjectSE getConsumerMonitor()

• getGroupId

  StringSE getGroupId()

• getConsumer

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

• getRecord

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

• getTopicPartition

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

• getOffsets

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

• isRolledBack

  boolean isRolledBack()

• setRolledBack

  void setRolledBack(boolean rolledBack)

• isAckDeferred

  boolean isAckDeferred()

• setAckDeferred

  void setAckDeferred(boolean ackDeferred)