Class RoutingKafkaTemplate

java.lang.Object
org.springframework.kafka.core.KafkaTemplate<Object,Object>
org.springframework.kafka.core.RoutingKafkaTemplate
All Implemented Interfaces:
EventListener, Aware, BeanNameAware, DisposableBean, SmartInitializingSingleton, ApplicationContextAware, ApplicationListener<ContextStoppedEvent>, KafkaOperations<Object,Object>

public class RoutingKafkaTemplate extends KafkaTemplate<Object,Object>
A KafkaTemplate that routes messages based on the topic name. Does not support transactions, flush(), metrics(), and execute(org.springframework.kafka.core.KafkaOperations.ProducerCallback), only simple send operations.
Since:
2.5
Author:
Gary Russell