org.opennms.core.ipc.sink.kafka.client
Classes
ConditionalKafkaSinkContext
KafkaLocalMessageDispatcherFactory
KafkaRemoteMessageDispatcherFactory