Package | Description |
---|---|
org.opennms.core.ipc.common.kafka | |
org.opennms.core.ipc.rpc.kafka | |
org.opennms.core.ipc.sink.kafka.server | |
org.opennms.core.ipc.sink.kafka.server.offset |
Modifier and Type | Class and Description |
---|---|
class |
OnmsKafkaConfigProvider |
class |
OsgiKafkaConfigProvider |
Constructor and Description |
---|
KafkaHealthCheck(KafkaConfigProvider kafkaConfigProvider,
String type) |
Constructor and Description |
---|
KafkaRpcServerManager(KafkaConfigProvider configProvider,
MinionIdentity minionIdentity,
TracerRegistry tracerRegistry) |
Constructor and Description |
---|
KafkaMessageConsumerManager(KafkaConfigProvider configProvider) |
KafkaMessageConsumerManager(KafkaConfigProvider configProvider,
Identity identity,
TracerRegistry tracerRegistry,
com.codahale.metrics.MetricRegistry metricRegistry) |
Constructor and Description |
---|
KafkaOffsetProvider(KafkaConfigProvider configProvider,
com.codahale.metrics.MetricRegistry metricRegistry) |
Copyright © 2020. All rights reserved.