José Valim

Actually, we should likely use Explorer for parsing instead of NimbleCSV.

Nothing obvious come to mind, unfortunately.

I am looking at the code and I cannot see a code path that would make the error message above happen. Every time we cancel the timer, we delete the...

Hi @anoskov! I recommend reaching out to ElixirForum for general help/questions, as it is more likely someone with a similar issue as yours can see your report.

@prabello have you tried using `Broadway.stop(NameOfYourTopology)`?

@prabello it is the name you give to `Broadway.start_link`. Apparently the function is not documented though, we would have to fix that first.

`Broadway.stop` will send a shutdown exit, this will make producers stop fetching and processors to clear their buffers. For the partitions assigned to the processor that has called `Broadway.stop`, no...

No! It is always at the end. I have updated the previous comment for clarity. :)

The proposed back-off in Broadway is that it is really just a safety net. For example, imagine that in your `handle_message` you need to perform 3 tasks. If the task...

@victorolinasc the docs are already explicit about this: > broadway_kafka never stops the flow of the stream, i.e. it will always ack the messages even when they fail. However, if...