Class KafkaAlarmDataSync
- java.lang.Object
-
- org.opennms.features.kafka.producer.datasync.KafkaAlarmDataSync
-
- All Implemented Interfaces:
java.lang.Runnable
,AlarmDataStore
public class KafkaAlarmDataSync extends java.lang.Object implements AlarmDataStore, java.lang.Runnable
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
KAFKA_STREAMS_PID
-
Constructor Summary
Constructors Constructor Description KafkaAlarmDataSync(org.osgi.service.cm.ConfigurationAdmin configAdmin, OpennmsKafkaProducer kafkaProducer, ProtobufMapper protobufMapper)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
destroy()
OpennmsModelProtos.Alarm
getAlarm(java.lang.String reductionKey)
java.util.Map<java.lang.String,OpennmsModelProtos.Alarm>
getAlarms()
AlarmSyncResults
handleAlarmSnapshot(java.util.List<OnmsAlarm> alarms)
void
init()
This method initializes the stream client, but doesn't actually start it until an alarm is forwarded by the producer.boolean
isEnabled()
boolean
isReady()
void
run()
void
setAlarmSync(boolean alarmSync)
void
setAlarmTopic(java.lang.String alarmTopic)
void
setStartWithCleanState(boolean startWithCleanState)
void
setSuppressIncrementalAlarms(boolean suppressIncrementalAlarms)
-
-
-
Field Detail
-
KAFKA_STREAMS_PID
public static final java.lang.String KAFKA_STREAMS_PID
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
KafkaAlarmDataSync
public KafkaAlarmDataSync(org.osgi.service.cm.ConfigurationAdmin configAdmin, OpennmsKafkaProducer kafkaProducer, ProtobufMapper protobufMapper)
-
-
Method Detail
-
init
public void init() throws java.io.IOException
This method initializes the stream client, but doesn't actually start it until an alarm is forwarded by the producer.- Specified by:
init
in interfaceAlarmDataStore
- Throws:
java.io.IOException
- when an error occurs in loading/parsing the Kafka client/stream configuration
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
destroy
public void destroy()
- Specified by:
destroy
in interfaceAlarmDataStore
-
handleAlarmSnapshot
public AlarmSyncResults handleAlarmSnapshot(java.util.List<OnmsAlarm> alarms)
- Specified by:
handleAlarmSnapshot
in interfaceAlarmDataStore
-
setAlarmTopic
public void setAlarmTopic(java.lang.String alarmTopic)
-
setAlarmSync
public void setAlarmSync(boolean alarmSync)
-
setStartWithCleanState
public void setStartWithCleanState(boolean startWithCleanState)
- Specified by:
setStartWithCleanState
in interfaceAlarmDataStore
-
isEnabled
public boolean isEnabled()
- Specified by:
isEnabled
in interfaceAlarmDataStore
-
isReady
public boolean isReady()
- Specified by:
isReady
in interfaceAlarmDataStore
-
getAlarms
public java.util.Map<java.lang.String,OpennmsModelProtos.Alarm> getAlarms()
- Specified by:
getAlarms
in interfaceAlarmDataStore
-
getAlarm
public OpennmsModelProtos.Alarm getAlarm(java.lang.String reductionKey)
- Specified by:
getAlarm
in interfaceAlarmDataStore
-
setSuppressIncrementalAlarms
public void setSuppressIncrementalAlarms(boolean suppressIncrementalAlarms)
-
-