Class PollableKafkaChannel

All Implemented Interfaces:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, ExecutorChannelInterceptorAware, ExpressionCapable, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, MessageChannel, PollableChannel, InterceptableChannel

public class PollableKafkaChannel
extends AbstractKafkaChannel
implements PollableChannel, ExecutorChannelInterceptorAware
Pollable channel backed by an Apache Kafka topic.
Since:
5.4
Author:
Gary Russell, Artem Bilan