Package org.opennms.netmgt.flows.persistence

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

Modifier and Type	Method	Description
void	destroy()
void	forward(EnrichedFlow enrichedFlow)
void	init()
void	setTopicName(String topicName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

KAFKA_CLIENT_PID

public static final String KAFKA_CLIENT_PID

See Also:

Constant Field Values

Constructor Detail

KafkaFlowForwarder

public KafkaFlowForwarder(org.osgi.service.cm.ConfigurationAdmin configAdmin,
                          com.codahale.metrics.MetricRegistry metricRegistry)

Method Detail

forward

public void forward(EnrichedFlow enrichedFlow)

Specified by:

forward in interface EnrichedFlowForwarder

init

public void init()
          throws IOException

Throws:

IOException

destroy

public void destroy()

setTopicName

public void setTopicName(String topicName)