public class KafkaPublishSubscribeChannelSpec extends KafkaSubscribableChannelSpec<PublishSubscribeKafkaChannel>
groupId| Modifier | Constructor and Description |
|---|---|
protected |
KafkaPublishSubscribeChannelSpec(org.springframework.kafka.core.KafkaTemplate<?,?> template,
org.springframework.kafka.config.KafkaListenerContainerFactory<?> factory,
java.lang.String topic) |
groupId, iddatatype, doGet, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTap_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop