13 lines
282 B
YAML
13 lines
282 B
YAML
input:
|
|
nats_jetstream:
|
|
urls: ["nats://nats:4222"]
|
|
subject: "user.updates"
|
|
stream: "request_stream"
|
|
|
|
pipeline:
|
|
processors:
|
|
- mapping: |
|
|
root.id = this.id
|
|
root.username = this.username
|
|
root.email = this.email
|
|
root.updated_at = now() |