Class PublishSubscribeKafkaChannel

All Implemented Interfaces:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, BroadcastCapableChannel, ExpressionCapable, IntegrationPattern, NamedComponent, IntegrationManagement, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent, MessageChannel, SubscribableChannel, InterceptableChannel

public class PublishSubscribeKafkaChannel
extends SubscribableKafkaChannel
implements BroadcastCapableChannel
Publish/subscribe channel backed by an Apache Kafka topic.
Since:
5.4
Author:
Gary Russell
  • Constructor Details

    • PublishSubscribeKafkaChannel

      public PublishSubscribeKafkaChannel​(org.springframework.kafka.core.KafkaOperations<?,​?> template, org.springframework.kafka.config.KafkaListenerContainerFactory<?> factory, String channelTopic)
      Construct an instance with the provided parameters.
      Parameters:
      template - template for sending.
      factory - factory for creating a container for receiving.
      channelTopic - the topic.
  • Method Details