Index

D E K O P S T
All Classes and Interfaces|All Packages|Constant Field Values

D

DynamicKafkaListenerFactory - Interface in kimaira.kafka

DynamicKafkaListenerFactoryImpl - Class in kimaira.kafka

DynamicKafkaListenerFactoryImpl(ConcurrentKafkaListenerContainerFactory<String, String>, KafkaOps) - Constructor for class kimaira.kafka.DynamicKafkaListenerFactoryImpl

DynamicKafkaListenerFactoryImpl.RecordHandler<K,V> - Interface in kimaira.kafka

E

ensureTopic(String) - Method in interface kimaira.kafka.KafkaOps

ensureTopic(String) - Method in class kimaira.kafka.KafkaOpsImpl

Create if missing; increase partitions if smaller than requested (no decrease).

K

KafkaOps - Interface in kimaira.kafka

KafkaOpsImpl - Class in kimaira.kafka

KafkaOpsImpl(KafkaAdmin) - Constructor for class kimaira.kafka.KafkaOpsImpl

KafkaUtils - Class in kimaira.kafka

kimaira.kafka - package kimaira.kafka

O

onMessage(ConsumerRecord<K, V>, Acknowledgment) - Method in interface kimaira.kafka.DynamicKafkaListenerFactoryImpl.RecordHandler

P

ProducerService - Interface in kimaira.kafka

ProducerServiceImpl - Class in kimaira.kafka

ProducerServiceImpl(KafkaTemplate<String, String>, KafkaOps) - Constructor for class kimaira.kafka.ProducerServiceImpl

S

send(String, ModalType, String) - Method in interface kimaira.kafka.ProducerService

send(String, ModalType, String) - Method in class kimaira.kafka.ProducerServiceImpl

startTopicListener(String, DynamicKafkaListenerFactoryImpl.RecordHandler<String, String>) - Method in interface kimaira.kafka.DynamicKafkaListenerFactory

startTopicListener(String, DynamicKafkaListenerFactoryImpl.RecordHandler<String, String>) - Method in class kimaira.kafka.DynamicKafkaListenerFactoryImpl

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

stopAll() - Method in class kimaira.kafka.DynamicKafkaListenerFactoryImpl

Stop all dynamic listeners (called automatically at shutdown).

stopListener(String) - Method in interface kimaira.kafka.DynamicKafkaListenerFactory

stopListener(String) - Method in class kimaira.kafka.DynamicKafkaListenerFactoryImpl

Stop (and remove) a running listener by id.

T

TOPIC_PREFIX - Static variable in class kimaira.kafka.KafkaUtils

D E K O P S T
All Classes and Interfaces|All Packages|Constant Field Values