same source input many sinks problem

[lddlww]

same source： kafka
different many sinks：databend，elasticsearch

simple config.yaml: difference sinks using same source input source-kafka

vim sources/source-kafka.yaml
type: kafka

vim sinks/sink-databend.yaml
type: databend
inputs:
 - source-kafka

vim sinks/sink-es.yaml
type: elasticsearch
inputs:
 - source-kafka

if elasticsearch run abnormal and blocked，which will result databend sink be blocked，it is right? reference follow code：

vector/src/topology/builder.rs

Line 255 in 029a2ff

fanout

vector/lib/vector-core/src/fanout.rs

Line 427 in 029a2ff

pending!();

becausesender_group.send function will pending, if one of sinks run abnormal?

if not, am i missing something?

best wishes

[jszwedko]

if elasticsearch run abnormal and blocked，which will result databend sink be blocked，it is right? reference follow code：

This is expected. https://vector.dev/docs/about/concepts/#backpressure has more details. You can avoid this by configuring the buffer for a sink to drop events rather than apply back-pressure.