org.opennms.features.kafka.producer.collection

Class KafkaPersister

java.lang.Object

org.opennms.features.kafka.producer.collection.KafkaPersister

All Implemented Interfaces:

CollectionSetVisitor, Persister

public class KafkaPersister
extends Object
implements Persister

Constructor Summary

Constructors

Constructor and Description
KafkaPersister()

Method Summary

Modifier and Type	Method and Description
void	completeAttribute(CollectionAttribute attribute) completeAttribute
void	completeCollectionSet(CollectionSet set) completeCollectionSet
void	completeGroup(AttributeGroup group) completeGroup
void	completeResource(CollectionResource resource) completeResource
void	persistNumericAttribute(CollectionAttribute attribute) persistNumericAttribute
void	persistStringAttribute(CollectionAttribute attribute) persistStringAttribute
void	setCollectionSetMapper(CollectionSetMapper collectionSetMapper)
void	setProducer(org.apache.kafka.clients.producer.KafkaProducer<String,byte[]> producer)
void	setTopicName(String topicName)
void	visitAttribute(CollectionAttribute attribute) visitAttribute
void	visitCollectionSet(CollectionSet collectionSet) visitCollectionSet
void	visitGroup(AttributeGroup group) visitGroup
void	visitResource(CollectionResource resource) visitResource

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaPersister

public KafkaPersister()

Method Detail

visitCollectionSet

public void visitCollectionSet(CollectionSet collectionSet)

visitCollectionSet

Specified by:

visitCollectionSet in interface CollectionSetVisitor

Parameters:

collectionSet - a org.opennms.netmgt.collectd.CollectionSet object.

setTopicName

public void setTopicName(String topicName)

setProducer

public void setProducer(org.apache.kafka.clients.producer.KafkaProducer<String,byte[]> producer)

setCollectionSetMapper

public void setCollectionSetMapper(CollectionSetMapper collectionSetMapper)

visitResource

public void visitResource(CollectionResource resource)

Description copied from interface: CollectionSetVisitor

visitResource

Specified by:

visitResource in interface CollectionSetVisitor

Parameters:

resource - a CollectionResource object.

visitGroup

public void visitGroup(AttributeGroup group)

Description copied from interface: CollectionSetVisitor

visitGroup

Specified by:

visitGroup in interface CollectionSetVisitor

Parameters:

group - a org.opennms.netmgt.collectd.AttributeGroup object.

visitAttribute

public void visitAttribute(CollectionAttribute attribute)

Description copied from interface: CollectionSetVisitor

visitAttribute

Specified by:

visitAttribute in interface CollectionSetVisitor

Parameters:

attribute - a org.opennms.netmgt.collection.api.collectd.CollectionAttribute object.

completeAttribute

public void completeAttribute(CollectionAttribute attribute)

Description copied from interface: CollectionSetVisitor

completeAttribute

Specified by:

completeAttribute in interface CollectionSetVisitor

Parameters:

attribute - a org.opennms.netmgt.collection.api.collectd.CollectionAttribute object.

completeGroup

public void completeGroup(AttributeGroup group)

Description copied from interface: CollectionSetVisitor

completeGroup

Specified by:

completeGroup in interface CollectionSetVisitor

Parameters:

group - a org.opennms.netmgt.collectd.AttributeGroup object.

completeResource

public void completeResource(CollectionResource resource)

Description copied from interface: CollectionSetVisitor

completeResource

Specified by:

completeResource in interface CollectionSetVisitor

Parameters:

resource - a CollectionResource object.

completeCollectionSet

public void completeCollectionSet(CollectionSet set)

Description copied from interface: CollectionSetVisitor

completeCollectionSet

Specified by:

completeCollectionSet in interface CollectionSetVisitor

Parameters:

set - a org.opennms.netmgt.collectd.CollectionSet object.

persistNumericAttribute

public void persistNumericAttribute(CollectionAttribute attribute)

Description copied from interface: Persister

persistNumericAttribute

Specified by:

persistNumericAttribute in interface Persister

Parameters:

attribute - a CollectionAttribute object.

persistStringAttribute

public void persistStringAttribute(CollectionAttribute attribute)

Description copied from interface: Persister

persistStringAttribute

Specified by:

persistStringAttribute in interface Persister

Parameters:

attribute - a CollectionAttribute object.