Class KafkaFlowForwarder
- java.lang.Object
-
- org.opennms.netmgt.flows.persistence.KafkaFlowForwarder
-
- All Implemented Interfaces:
EnrichedFlowForwarder
public class KafkaFlowForwarder extends Object implements EnrichedFlowForwarder
-
-
Field Summary
Fields Modifier and Type Field Description static String
KAFKA_CLIENT_PID
-
Constructor Summary
Constructors Constructor Description KafkaFlowForwarder(org.osgi.service.cm.ConfigurationAdmin configAdmin, com.codahale.metrics.MetricRegistry metricRegistry)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
destroy()
void
forward(EnrichedFlow enrichedFlow)
void
init()
void
setTopicName(String topicName)
-
-
-
Field Detail
-
KAFKA_CLIENT_PID
public static final String KAFKA_CLIENT_PID
- See Also:
- Constant Field Values
-
-
Method Detail
-
forward
public void forward(EnrichedFlow enrichedFlow)
- Specified by:
forward
in interfaceEnrichedFlowForwarder
-
init
public void init() throws IOException
- Throws:
IOException
-
destroy
public void destroy()
-
setTopicName
public void setTopicName(String topicName)
-
-