NATS JetStream Inputs

George Alpizar
George Alpizar
  • Updated

Overview

This input type allows you to specify a NATS stream subscription for Edge Delta to monitor. 

Review Parameters

Review the following parameters that you can configure in the Edge Delta App:

Visual Editor YAML Description
Not applicable labels

Enter a descriptive name for this input. 

When you create a workflow, you will use this label to enter your input into the workflow. 

This parameter is required. 

Review the following example: 

labels: "my-nats-normal"
Not applicable input_mode

Enter normal or distributed based on your sources. 

If you only need to specify one source, then enter normal for non-complex configurations.

If you need to specify multiple sources, then enter distributed.

Review the following example: 

input_mode: "normal"
Not applicable consumer_mode

Enter pull or push, based on if the consumer is push-based or pull-based.

Review the following example: 

consumer_mode: "pull"
Not applicable cluster_url

Enter the NATS cluster endpoint. 

Review the following example: 

cluster_url: "nats://localhost:4222"
Not applicable stream_name

Enter the name of the stream where the input can obtain data from. 

Review the following example: 

stream_name: "example-stream"
Not applicable subject

Enter the channel where the input can obtain data from. 

Review the following example: 

subject: "example-subject-1"
Not applicable timeout

Enter a length of time when the request will be "timed out" in the NATS cluster. 

The default value is 10s.

Review the following example: 

timeout: 1m
Not applicable ack_wait_durations

Enter a length of time that a delivered message can remain unacknowledged before a redelivery is attempted. 

The default value is 5s.

Review the following example: 

ack_wait_duration: 10s
Not applicable subject_prefix

Review the following example: 

subject_prefix: "example-subject"
Not applicable total_agent_count

Enter the number of agents that should listen to the specified stream. This number will be used to calculate which subjects the input will listen from.

 

Note

To use this parameter, you must also set the agent name via the 'ED_NATS_AGENT_NAME' environment variable.

To learn more, see Variables.

 Review the following example: 

total_agent_count: 5
Not applicable total_subject_count

Enter the number of subjects to create in advance. This value should be a fixed number. 

Review the following example: 

total_subject_count: 10
Not applicable should_split_lines

Enter true or false to split the obtained payload into separate lines, based on the newline character. 

Review the following example:

should_split_lines: true
Not applicable disable_acks

Enter true or false to ignore (not acknowledge) any message after the message is consumed. 

Enter true to ignore messages. 

Enter false to acknowledge messages. 

The default value is false. 

Review the following example: 

disable_acks: true

 

Review Sample Configuration

Review the following sample configuration: 

  nats:
    - labels: "my-nats-normal"
      input_mode: "normal"
      consumer_mode: "pull"
      cluster_url: "nats://localhost:4222"
      stream_name: "example-stream"
      subject: "example-subject-1"
      timeout: 1m
      ack_wait_duration: 10s
    - labels: "my-nats-distributed"
      input_mode: "distributed"
      consumer_mode: "push"
      cluster_url: "nats://localhost:4222"
      stream_name: "example-stream"
      subject_prefix: "example-subject"
      total_agent_count: 5
      total_subject_count: 10
      should_split_lines: true
      timeout: 1m
      disable_acks: true
Share this document