NATS Consumer
The NATS Consumer operator consumes messages from NATS and forwards them to the output port.
Configuration Parameters
|
Parameter |
Type |
Description |
|---|---|---|
|
natsUrls |
string |
Mandatory. The NATS address. Default: "nats://localhost:4222" |
|
queue |
string |
The queue name to form the messages queue group. Default: "" |
|
subject |
string |
Mandatory. The subject name to subscribe to. Default: "subject" |
|
numRetryAttempts |
int |
The number of attempts to retry. Default: 0 |
|
retryPeriodInMs |
int |
The time period for each retry in milliseconds. Default: 0 |
Input
None
Output
|
Output |
Type |
Description |
|---|---|---|
|
out |
message |
The stream of records published. |