Package kimaira.kafka

Class DynamicKafkaListenerFactoryImpl

java.lang.Object

kimaira.kafka.DynamicKafkaListenerFactoryImpl

All Implemented Interfaces:

DynamicKafkaListenerFactory

@Service("dynamicKafkaListenerFactory")
public class DynamicKafkaListenerFactoryImpl
extends Object
implements DynamicKafkaListenerFactory

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	DynamicKafkaListenerFactoryImpl.RecordHandler<K,V>

Constructor Summary

Constructors

Constructor	Description
DynamicKafkaListenerFactoryImpl(org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<String,String> baseFactory, KafkaOps kafkaOps)

Method Summary

Modifier and Type	Method	Description
String	startTopicListener(String topic, DynamicKafkaListenerFactoryImpl.RecordHandler<String,String> handler)	Start a listener for a single topic; returns the runtime container id.
void	stopAll()	Stop all dynamic listeners (called automatically at shutdown).
void	stopListener(String id)	Stop (and remove) a running listener by id.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DynamicKafkaListenerFactoryImpl

public DynamicKafkaListenerFactoryImpl(org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<String,String> baseFactory,
 KafkaOps kafkaOps)

Method Details

startTopicListener

public String startTopicListener(String topic,
 DynamicKafkaListenerFactoryImpl.RecordHandler<String,String> handler)

Start a listener for a single topic; returns the runtime container id.

Specified by:

startTopicListener in interface DynamicKafkaListenerFactory

stopListener

public void stopListener(String id)

Stop (and remove) a running listener by id. Safe to call multiple times.

Specified by:

stopListener in interface DynamicKafkaListenerFactory

stopAll

@PreDestroy
public void stopAll()

Stop all dynamic listeners (called automatically at shutdown).