Class BmpKafkaProducer
- java.lang.Object
-
- org.opennms.netmgt.telemetry.protocols.bmp.adapter.openbmp.BmpKafkaProducer
-
- All Implemented Interfaces:
BmpMessageHandler
public class BmpKafkaProducer extends java.lang.Object implements BmpMessageHandler
-
-
Constructor Summary
Constructors Constructor Description BmpKafkaProducer(java.lang.String topicPrefix, java.util.Map<java.lang.String,java.lang.Object> kafkaConfig)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
handle(Message message, Context context)
-
-
-
Method Detail
-
handle
public void handle(Message message, Context context)
- Specified by:
handle
in interfaceBmpMessageHandler
-
close
public void close()
- Specified by:
close
in interfaceBmpMessageHandler
-
-