KafkaMessageSource.KafkaAckInfo (Spring Integration 5.5.0-M3 API)

Type Parameters:: K - the key type.; V - the value type.

All Superinterfaces:: Comparable<KafkaMessageSource.KafkaAckInfo<K,V>>

All Known Implementing Classes:: KafkaMessageSource.KafkaAckInfoImpl

Enclosing class:: KafkaMessageSource<K,V>

public static interface KafkaMessageSource.KafkaAckInfo<K,V>
extends Comparable<KafkaMessageSource.KafkaAckInfo<K,V>>

Information for building an KafkaAckCallback.

Method Summary

Modifier and Type	Method	Description
`org.apache.kafka.clients.consumer.Consumer<K,V>`	`getConsumer()`
`Object`	`getConsumerMonitor()`
`String`	`getGroupId()`
`Map<org.apache.kafka.common.TopicPartition,Set<KafkaMessageSource.KafkaAckInfo<K,V>>>`	`getOffsets()`
`org.apache.kafka.clients.consumer.ConsumerRecord<K,V>`	`getRecord()`
`org.apache.kafka.common.TopicPartition`	`getTopicPartition()`
`boolean`	`isAckDeferred()`
`boolean`	`isRolledBack()`
`void`	`setAckDeferred(boolean ackDeferred)`
`void`	`setRolledBack(boolean rolledBack)`

Methods inherited from interface java.lang.Comparable

compareTo

Method Details
- getConsumerMonitor
  
  Object getConsumerMonitor()
- getGroupId
  
  String 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
  
  Map<org.apache.kafka.common.TopicPartition,Set<KafkaMessageSource.KafkaAckInfo<K,V>>> getOffsets()
- isRolledBack
  
  boolean isRolledBack()
- setRolledBack
  
  void setRolledBack(boolean rolledBack)
- isAckDeferred
  
  boolean isAckDeferred()
- setAckDeferred
  
  void setAckDeferred(boolean ackDeferred)