Spring connector
Audience: operators bridging EventMesh with Spring. Spring application bridge. Source buffers events published by Spring code (register a producer that feeds the buffer); sink exposes an injectable EventForwarder so the hosting Spring context receives EventMesh deliveries as native events.
Classes
| Direction | Class | Behavior |
|---|---|---|
| Source | org.apache.eventmesh.connector.spring.source.SpringSourceConnector | A LinkedBlockingQueue feeds poll(); host Spring code (e.g. an @EventListener adapter) enqueues CloudEvents. |
| Sink | org.apache.eventmesh.connector.spring.sink.SpringSinkConnector | Calls the injected EventForwarder.forward(event) per CloudEvent. Fail-fast: until the Spring context wires a forwarder via setForwarder(...), put() throws so the runtime redelivers instead of silently dropping events. |
Source configuration
| Key | Default | Description |
|---|---|---|
(none) | — | The source needs no external config |
Sink configuration
| Key | Default | Description |
|---|---|---|
(none) | — | Wire the forwarder programmatically from the Spring context |
Running
Host inside a Spring Boot app; call SpringSinkConnector.setForwarder(event -> publisher.publishEvent(...)) after init