-
For Removal Element Description org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate.flush() - flush does not make sense in the context of a reactive flow since, the send completion signal is a send result, which implies that a flush is redundant. If you use this method with reactor-kafka 1.3 or later, it must be scheduled to avoid a deadlock; see https://issues.apache.org/jira/browse/KAFKA-10790
-
Classes Class Description org.springframework.kafka.transaction.ChainedKafkaTransactionManager Refer to theChainedTransactionManager
javadocs.
-
Methods Method Description org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate.flush() - flush does not make sense in the context of a reactive flow since, the send completion signal is a send result, which implies that a flush is redundant. If you use this method with reactor-kafka 1.3 or later, it must be scheduled to avoid a deadlock; see https://issues.apache.org/jira/browse/KAFKA-10790org.springframework.kafka.listener.ContainerProperties.getConsumerStartTimout() org.springframework.kafka.listener.ContainerProperties.setConsumerStartTimout(Duration) org.springframework.kafka.listener.ContainerProperties.setTransactionDefinition(TransactionDefinition) Refer to theChainedTransactionManager
javadocs.org.springframework.kafka.listener.FailedRecordProcessor.getSkipPredicate(List<ConsumerRecord<?, ?>>, Exception) org.springframework.kafka.listener.ListenerUtils.unrecoverableBackOff(BackOff, ThreadLocal<BackOffExecution>, ThreadLocal<Long>)