Add an SNMP source connector
Built SeaTunnel's first SNMP source, polling explicit numeric OIDs through SNMPv2c GET and emitting agent, OID, value, SMI type, and timestamp records.
apache/seatunnel · #11968
New infrastructure connector
SeaTunnel can now poll SNMPv2c agents in batch or streaming jobs while keeping community credentials out of logs and errors.
Problem
SeaTunnel could not ingest operational metrics from SNMP-managed infrastructure. The connector needed deterministic batch and streaming behavior, serializable worker state, bounded retry and timeout controls, resource-safe cancellation, and confidential treatment of the SNMP community value.
Approach
Implemented one-shot batch and interval-based streaming polling over UDP with SNMP4J, a fixed output schema, timeout and retry configuration, error propagation, cancellation cleanup, connector packaging, license metadata, and English and Chinese documentation.
Impact and scope
- Adds a direct ingestion path for network devices and infrastructure that expose operational state through SNMP.
- Supports both bounded snapshots and continuous polling without introducing external-device dependencies into the test suite.
- Treats the community value as sensitive and closes transport resources cleanly during cancellation and failure.
Validation
- Added 18 tests for configuration, factory options, batch and streaming readers, serialization, cleanup, errors, response conversion, and a local UDP protocol round trip.
- Focused tests and scoped reactor verification passed on JDK 8 and JDK 11; the final Apache Build also passed.
- Both authored commits and the final merge commit are attributable to Goutam Adwant; the GitHub-verified merge received upstream approval.