Uses of Enum Class
org.springframework.kafka.listener.ContainerProperties.EOSMode
Packages that use ContainerProperties.EOSMode
-
Uses of ContainerProperties.EOSMode in org.springframework.kafka.listener
Methods in org.springframework.kafka.listener that return ContainerProperties.EOSModeModifier 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.Methods in org.springframework.kafka.listener with parameters of type ContainerProperties.EOSModeModifier 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) default void
AfterRollbackProcessor.processBatch
(org.apache.kafka.clients.consumer.ConsumerRecords<K, V> records, List<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> recordList, org.apache.kafka.clients.consumer.Consumer<K, V> consumer, MessageListenerContainer container, Exception exception, boolean recoverable, ContainerProperties.EOSMode eosMode) Process the entire batch of records.void
DefaultAfterRollbackProcessor.processBatch
(org.apache.kafka.clients.consumer.ConsumerRecords<K, V> records, List<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> recordList, 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.