Error when running NATS Jetstream as input in redpanda connect(formerly Benthos) in multiple pods.

[BenBasilTomy]

I am running a redpanda connect with NATS Jetstream as input and getting an error:
"Failed to connect to nats_jetstream: cannot create a queue subscription for a consumer without a deliver group."
But as per redpanda connect documentation there is no config field for NATS Jetstream input as deliver group. How to solve this? Below is my input configuration:

input:
  label: orders_publisher
  nats_jetstream:
    urls: [nats://nats:4222]
    subject: awsloadtest
    stream: orders
    queue: testqueue
    durable: awsloadtest 
    ack_wait: 30s
    max_ack_pending: 1000
    deliver: all

[jnmoyne]

This is more of a Benthos than NATS question, but that error message seems to indicate you are trying to subscribe to a consumer using a queue group (I'm guessing the queue: testqueue line in your configuration, which is something you only need when subscribing to a push consumer, while the consumer you are trying to use (the durable: awsloadtest in your config) is configured as a pull consumer. Please check the Benthos documentation for how to configure it to get data from a pull consumer.

[BenBasilTomy]

Hi,
Thank you for pointing that out. The issue was indeed caused by using both queue and durable in the configuration. Removing the durable field from the Benthos configuration resolved the problem. However, I found the error message to be somewhat misleading.