DynamicKafkaListenerFactory (ai.telosforge:kimaira-starter-kafka 1.2.4 API)

All Known Implementing Classes:: DynamicKafkaListenerFactoryImpl

public interface DynamicKafkaListenerFactory

Method Summary

Modifier and Type

Method

Description

String

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

void

stopListener(String id)

Method Details
- startTopicListener
  
  String startTopicListener(String topic, DynamicKafkaListenerFactoryImpl.RecordHandler<String,String> handler)
- stopListener
  
  void stopListener(String id)