Fix slow kafka sink when queue.buffering.max.ms is set to > 0.#585

Merged

Licenser merged 4 commits intomainfrom kafka-sink-hang

Nov 12, 2020

+236-44

Commits on Nov 12, 2020

Fix slow kafka sink when queue.buffering.max.ms is set to > 0.
Matthias Wahl
committed
clippy, clippy, joy, joy
Matthias Wahl
committed
Flush messages for 1 sec before terminating kafka sink if we have in flight messages.
Matthias Wahl
committed
oh you, clippy!
Matthias Wahl
committed