jcustenborder/kafka-connect-snmp

Kafka Connect connector for receiving SNMP data.

Introduction

This connector is used to receive data from devices via SNMP. This connector will receive SNMP traps and convert them to a record in Kafka.

Configuration

SnmpTrapSourceConnector

name=MySinkConnector
connector.class=com.github.jcustenborder.kafka.connect.snmp.SnmpTrapSourceConnector

Name	Description	Type	Default	Valid Values	Importance
topic	topic	string			high
batch.size	Number of records to return in a single batch.	int	1024	[10,...,2147483647]	medium
poll.backoff.ms	The amount of time in ms to wait if no records are returned.	long	250	[10,...,2147483647]	medium
dispatcher.thread.pool.size	Number of threads to allocate for the thread pool.	int	10	[1,...,100]	low
listen.address	IP address to listen for messages on.	string	0.0.0.0		low
listen.port	Port to listen on.	int	10161	ValidPort{start=1025, end=65535}	low
listen.protocol	Protocol to listen with..	string	UDP	[UDP, TCP]	low

Running in development

The docker-compose.yml that is included in this repository is based on the Confluent Platform Docker images. Take a look at the quickstart for the Docker images.

The hostname confluent must be resolvable by your host. You will need to determine the ip address of your docker-machine using docker-machine ip confluent and add this to your /etc/hosts file. For example if docker-machine ip confluent returns 192.168.99.100 add this:

192.168.99.100  confluent

docker-compose up -d

Start the connector with debugging enabled.

./bin/debug.sh

Start the connector with debugging enabled. This will wait for a debugger to attach.

export SUSPEND='y'
./bin/debug.sh

kafka-connect-snmp's Issues

SnmpTrapSourceConnector.properties needs topic property

I was unable to start the connector until I added a topic to the SnmpTrapSourceConnector.properties file.

After specifying a topic it appeared to start successfully.

OID

Hello,Snmp get data by OID, but I don't find the complete oid file?

connector only supports V2 traps

I am trying to get traps from Oracle Enterprise Manager into a kafka stream. OEM only supports V1 and V3 traps, but the kafka-connect-snmp connector only supports V2 traps. My knowledge of SNMP in general and snmp4j in particular is very limited, any pointers on how to support V1 (preferably) would be welcome. Thanks

Listening for transport dt_socket at address: 5005

Hi Team,

I managed to run the debug.sh but it then comes and stop at this message "Listening for transport dt_socket at address: 5005" - So what should be done after this ?

Do you have to send the message at port 5005 or 10161 the default one ?

Please guide me through if anyone has it documented further steps.

Regards.
Prashant