Class Hierarchy
- java.lang.Object
- java.util.concurrent.CompletableFuture<T> (implements java.util.concurrent.CompletionStage<T>, java.util.concurrent.Future<V>)
- org.springframework.kafka.requestreply.RequestReplyFuture<K,
V, R> - org.springframework.kafka.requestreply.RequestReplyMessageFuture<K,
V> - org.springframework.kafka.requestreply.RequestReplyTypedMessageFuture<K,
V, P>
- org.springframework.kafka.requestreply.RequestReplyTypedMessageFuture<K,
- org.springframework.kafka.requestreply.RequestReplyFuture<K,
- org.springframework.kafka.requestreply.CorrelationKey
- org.springframework.kafka.core.KafkaTemplate<K,
V> (implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<E>, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.kafka.core.KafkaOperations<K, V>, org.springframework.beans.factory.SmartInitializingSingleton) - org.springframework.kafka.requestreply.ReplyingKafkaTemplate<K,
V, R> (implements org.springframework.kafka.listener.BatchMessageListener<K, V>, org.springframework.kafka.listener.ConsumerSeekAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.kafka.requestreply.ReplyingKafkaOperations<K, V, R>, org.springframework.context.SmartLifecycle) - org.springframework.kafka.requestreply.AggregatingReplyingKafkaTemplate<K,
V, R> (implements org.springframework.kafka.listener.BatchConsumerAwareMessageListener<K, V>)
- org.springframework.kafka.requestreply.AggregatingReplyingKafkaTemplate<K,
- org.springframework.kafka.requestreply.ReplyingKafkaTemplate<K,
- java.lang.Throwable (implements java.io.Serializable)
- java.lang.Exception
- java.lang.RuntimeException
- org.springframework.core.NestedRuntimeException
- org.springframework.kafka.KafkaException
- org.springframework.kafka.requestreply.KafkaReplyTimeoutException
- org.springframework.kafka.KafkaException
- org.springframework.core.NestedRuntimeException
- java.lang.RuntimeException
- java.lang.Exception
- java.util.concurrent.CompletableFuture<T> (implements java.util.concurrent.CompletionStage<T>, java.util.concurrent.Future<V>)
Interface Hierarchy
- org.springframework.kafka.requestreply.ReplyingKafkaOperations<K,
V, R>