diff --git a/internal/components/nats/stream_input_ordered.go b/internal/components/nats/stream_input_ordered.go index b2dbbc1..18b5ee7 100644 --- a/internal/components/nats/stream_input_ordered.go +++ b/internal/components/nats/stream_input_ordered.go @@ -39,12 +39,14 @@ deterministic message ordering. It is also resilient to consumer deletion. Default("all")). Field(service.NewStringField("start_time"). Description("An optional time from which to start message delivery. Only applicable when delivery_policy is set to 'by_start_time'"). + Optional(). Advanced()). Field(service.NewStringAnnotatedEnumField("replay_policy", map[string]string{ "original": "messages are sent in the same intervals in which they were stored on stream.", "instant": "messages are sent as fast as possible.", }). Description("the rate at which messages are sent to the consumer."). + Default("original"). Advanced()). Fields(connectionTailFields()...). Fields(inputTracingDocs()) diff --git a/resources/docker/Dockerfile.cgo b/resources/docker/Dockerfile.cgo index 43f6753..f9ede5a 100644 --- a/resources/docker/Dockerfile.cgo +++ b/resources/docker/Dockerfile.cgo @@ -14,7 +14,7 @@ RUN apt-get update && apt-get install -y --no-install-recommends libzmq3-dev # Build COPY . /go/src/github.com/wombatwisdom/wombat/ -RUN wombat TAGS=x_benthos_extra +RUN task TAGS=x_benthos_extra # Pack FROM debian:latest