Uses of Enum Class
org.springframework.kafka.listener.ContainerProperties.EOSMode
-
Uses of ContainerProperties.EOSMode in org.springframework.kafka.listener
Modifier and TypeMethodDescriptionContainerProperties.getEosMode()
Get the exactly once semantics mode.static ContainerProperties.EOSMode
Returns the enum constant of this class with the specified name.static ContainerProperties.EOSMode[]
ContainerProperties.EOSMode.values()
Returns an array containing the constants of this enum class, in the order they are declared.Modifier and TypeMethodDescriptionvoid
AfterRollbackProcessor.process
(List<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, org.apache.kafka.clients.consumer.Consumer<K, V> consumer, MessageListenerContainer container, Exception exception, boolean recoverable, ContainerProperties.EOSMode eosMode) Process the remaining records.void
DefaultAfterRollbackProcessor.process
(List<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, org.apache.kafka.clients.consumer.Consumer<K, V> consumer, MessageListenerContainer container, Exception exception, boolean recoverable, ContainerProperties.EOSMode eosMode) void
ContainerProperties.setEosMode
(ContainerProperties.EOSMode eosMode) Set the exactly once semantics mode.