nats

Under the hood, Benthos csv input uses the standard encoding/csv packages's csv.Reader struct.

The current implementation of csv input doesn't allow setting the LazyQuotes field.

We have a use case where we need to set the LazyQuotes field in order to make things work correctly.

i'm attempting to write a health check for a service that uses watermill and i'd like to be able to easily determine if the router is still up and running

Router exposes a channel at .Running(), and it's possible to infer if the router is closed with a little indirection:

running := false
go func() {
  r := router.Running()

  for {
    if _, open := <-r; open {
      running 

The SubscriberDeliveryTaskCount default should be set to something sane like 3. Currently it is zero which is too strongly biased toward high throughput with a low number of subscriptions and does not support many subscriptions in one application as one thread to be created per subscr

We should create an integration test that splits up a big file or it performs an expected mathematical operations on generating records, in a way that the output can be inferred and checked.

e.g.:

• splits up a 100MB video file into several 1MB files, sends to the commit log, re-assemble the file and checks md5 of the original and the re-assembled.
• create a series of events that have rando

Tracking issue