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