Uses of Interface
org.springframework.kafka.core.KafkaOperations
Package
Description
Package for kafka core components
Package for kafka listeners
Provides classes for request/reply semantics.
Package for retryable topic handling.
-
Uses of KafkaOperations in org.springframework.kafka.core
Modifier and TypeClassDescriptionclass
KafkaTemplate<K,
V> A template for executing high-level operations.class
AKafkaTemplate
that routes messages based on the topic name.Modifier and TypeMethodDescriptionKafkaOperations.OperationsCallback.doInOperations
(KafkaOperations<K, V> operations) -
Uses of KafkaOperations in org.springframework.kafka.listener
Modifier and TypeMethodDescriptionprotected Duration
DeadLetterPublishingRecoverer.determineSendTimeout
(KafkaOperations<?, ?> template) Determine the send timeout based on the template's producer factory andDeadLetterPublishingRecoverer.setWaitForSendResultTimeout(Duration)
.protected void
DeadLetterPublishingRecoverer.publish
(org.apache.kafka.clients.producer.ProducerRecord<Object, Object> outRecord, KafkaOperations<Object, Object> kafkaTemplate, org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> inRecord) Override this if you want more than just logging of the send result.protected void
DeadLetterPublishingRecoverer.send
(org.apache.kafka.clients.producer.ProducerRecord<Object, Object> outRecord, KafkaOperations<Object, Object> kafkaTemplate, org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> inRecord) Send the record.protected void
DeadLetterPublishingRecoverer.verifySendResult
(KafkaOperations<Object, Object> kafkaTemplate, org.apache.kafka.clients.producer.ProducerRecord<Object, Object> outRecord, CompletableFuture<SendResult<Object, Object>> sendResult, org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> inRecord) Wait for the send future to complete.ModifierConstructorDescriptionDeadLetterPublishingRecoverer
(KafkaOperations<? extends Object, ? extends Object> template) Create an instance with the provided template and a default destination resolving function that returns a TopicPartition based on the original topic (appended with ".DLT") from the failed record, and the same partition as the failed record.DeadLetterPublishingRecoverer
(KafkaOperations<? extends Object, ? extends Object> template, BiFunction<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>, Exception, org.apache.kafka.common.TopicPartition> destinationResolver) Create an instance with the provided template and destination resolving function, that receives the failed consumer record and the exception and returns aTopicPartition
.DefaultAfterRollbackProcessor
(BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>, Exception> recoverer, BackOff backOff, KafkaOperations<?, ?> kafkaOperations, boolean commitRecovered) Construct an instance with the provided recoverer which will be called after the backOff returns STOP for a topic/partition/offset.DefaultAfterRollbackProcessor
(BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>, Exception> recoverer, BackOff backOff, BackOffHandler backOffHandler, KafkaOperations<?, ?> kafkaOperations, boolean commitRecovered) Construct an instance with the provided recoverer which will be called after the backOff returns STOP for a topic/partition/offset.ModifierConstructorDescriptionDeadLetterPublishingRecoverer
(Function<org.apache.kafka.clients.producer.ProducerRecord<?, ?>, KafkaOperations<?, ?>> templateResolver, boolean transactional, BiFunction<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>, Exception, org.apache.kafka.common.TopicPartition> destinationResolver) Create an instance with a template resolving function that receives the failed consumer record and the exception and returns aKafkaOperations
and a flag on whether or not the publishing from this instance will be transactional or not.DeadLetterPublishingRecoverer
(Function<org.apache.kafka.clients.producer.ProducerRecord<?, ?>, KafkaOperations<?, ?>> templateResolver, BiFunction<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>, Exception, org.apache.kafka.common.TopicPartition> destinationResolver) Create an instance with a template resolving function that receives the failed consumer record and the exception and returns aKafkaOperations
and a flag on whether or not the publishing from this instance will be transactional or not.DeadLetterPublishingRecoverer
(Map<Class<?>, KafkaOperations<? extends Object, ? extends Object>> templates) Create an instance with the provided templates and a default destination resolving function that returns a TopicPartition based on the original topic (appended with ".DLT") from the failed record, and the same partition as the failed record.DeadLetterPublishingRecoverer
(Map<Class<?>, KafkaOperations<? extends Object, ? extends Object>> templates, BiFunction<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>, Exception, org.apache.kafka.common.TopicPartition> destinationResolver) Create an instance with the provided templates and destination resolving function, that receives the failed consumer record and the exception and returns aTopicPartition
. -
Uses of KafkaOperations in org.springframework.kafka.requestreply
Modifier and TypeClassDescriptionclass
A replying template that aggregates multiple replies with the same correlation id.class
ReplyingKafkaTemplate<K,
V, R> A KafkaTemplate that implements request/reply semantics. -
Uses of KafkaOperations in org.springframework.kafka.retrytopic
Modifier and TypeMethodDescriptionRetryTopicConfigurationBuilder.create
(KafkaOperations<?, ?> sendToTopicKafkaTemplate) Create theRetryTopicConfiguration
with the provided template.Modifier and TypeMethodDescriptionDeadLetterPublishingRecovererFactory.DeadLetterPublisherCreator.create
(Function<org.apache.kafka.clients.producer.ProducerRecord<?, ?>, KafkaOperations<?, ?>> templateResolver, BiFunction<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>, Exception, org.apache.kafka.common.TopicPartition> destinationResolver) Create aDeadLetterPublishingRecoverer
using the supplied properties.ModifierConstructorDescriptionDestinationTopicPropertiesFactory
(String retryTopicSuffix, String dltSuffix, List<Long> backOffValues, org.springframework.classify.BinaryExceptionClassifier exceptionClassifier, int numPartitions, KafkaOperations<?, ?> kafkaOperations, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy, long timeout) Construct an instance with the provided properties.DestinationTopicPropertiesFactory
(String retryTopicSuffix, String dltSuffix, List<Long> backOffValues, org.springframework.classify.BinaryExceptionClassifier exceptionClassifier, int numPartitions, KafkaOperations<?, ?> kafkaOperations, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy, long timeout, Map<String, Set<Class<? extends Throwable>>> dltRoutingRules) Construct an instance with the provided properties.Properties
(long delayMs, String suffix, org.springframework.kafka.retrytopic.DestinationTopic.Type type, int maxAttempts, int numPartitions, DltStrategy dltStrategy, KafkaOperations<?, ?> kafkaOperations, BiPredicate<Integer, Throwable> shouldRetryOn, long timeout) Create an instance with the provided properties with the DLT container starting automatically (if the container factory is so configured).Properties
(long delayMs, String suffix, org.springframework.kafka.retrytopic.DestinationTopic.Type type, int maxAttempts, int numPartitions, DltStrategy dltStrategy, KafkaOperations<?, ?> kafkaOperations, BiPredicate<Integer, Throwable> shouldRetryOn, long timeout, Boolean autoStartDltHandler) Create an instance with the provided properties.Properties
(long delayMs, String suffix, org.springframework.kafka.retrytopic.DestinationTopic.Type type, int maxAttempts, int numPartitions, DltStrategy dltStrategy, KafkaOperations<?, ?> kafkaOperations, BiPredicate<Integer, Throwable> shouldRetryOn, long timeout, Boolean autoStartDltHandler, Set<Class<? extends Throwable>> usedForExceptions) Create an instance with the provided properties.