public class KafkaPollableChannelSpec extends AbstractKafkaChannelSpec<KafkaPollableChannelSpec,PollableKafkaChannel>
groupId| Modifier | Constructor and Description |
|---|---|
protected |
KafkaPollableChannelSpec(org.springframework.kafka.core.KafkaTemplate<?,?> template,
KafkaMessageSource<?,?> source) |
groupId, iddatatype, doGet, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTap_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopprotected KafkaPollableChannelSpec(org.springframework.kafka.core.KafkaTemplate<?,?> template,
KafkaMessageSource<?,?> source)