Class Hierarchy
- java.lang.Object
- 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.kafka.requestreply.ReplyingKafkaTemplate<K,V,R> (implements org.springframework.kafka.listener.BatchMessageListener<K,V>, 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.ReplyingKafkaTemplate<K,V,R> (implements org.springframework.kafka.listener.BatchMessageListener<K,V>, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.kafka.requestreply.ReplyingKafkaOperations<K,V,R>, org.springframework.context.SmartLifecycle)
- org.springframework.util.concurrent.SettableListenableFuture<T> (implements org.springframework.util.concurrent.ListenableFuture<T>)
- org.springframework.kafka.requestreply.RequestReplyFuture<K,V,R>
- org.springframework.kafka.requestreply.RequestReplyMessageFuture<K,V>
- org.springframework.kafka.requestreply.RequestReplyTypedMessageFuture<K,V,P>
- 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
Interface Hierarchy
- org.springframework.kafka.requestreply.ReplyingKafkaOperations<K,V,R>