Amazon S3 connector
Audience: operators bridging EventMesh with Amazon S3. S3 object bridge. Source lists new objects in a bucket (cursor = last key); sink writes each CloudEvent as an object keyed by the event id.
Classes
| Direction | Class | Behavior |
|---|---|---|
| Source | org.apache.eventmesh.connector.s3.source.S3SourceConnector | ListObjectsV2 with startAfter(lastKey) each poll; new objects are fetched and emitted as CloudEvents, advancing the cursor. |
| Sink | org.apache.eventmesh.connector.s3.sink.S3SinkConnector | Puts each CloudEvent's payload as an object (id = key) into the target bucket. |
Source configuration
| Key | Default | Description |
|---|---|---|
connector.bucket | events | Source bucket |
connector.prefix | `` | Key prefix filter |
Sink configuration
| Key | Default | Description |
|---|---|---|
connector.bucket | sink | Target bucket |
Running
bin/start-connector.sh with -Dconnector.class=...S3SourceConnector -Dconnector.mode=source -Dconnector.bucket=incoming -Dconnector.prefix=2026/