Class KafkaPointToPointChannelSpec

All Implemented Interfaces:
Aware, BeanClassLoaderAware, BeanFactoryAware, DisposableBean, FactoryBean<SubscribableKafkaChannel>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration

public class KafkaPointToPointChannelSpec
extends KafkaSubscribableChannelSpec<SubscribableKafkaChannel>
Spec for a point to point channel backed by an Apache Kafka topic.
Since:
5.4
Author:
Gary Russell
  • Constructor Details

    • KafkaPointToPointChannelSpec

      protected KafkaPointToPointChannelSpec​(org.springframework.kafka.core.KafkaTemplate<?,​?> template, org.springframework.kafka.config.KafkaListenerContainerFactory<?> factory, String topic)