projects / collectd.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: fe51150) | patch
write_kafka: check for partition availability before selecting one
authorVincent Bernat <vincent@bernat.im>
Wed, 10 Dec 2014 14:41:49 +0000 (15:41 +0100)
committerVincent Bernat <vincent@bernat.im>
Wed, 10 Dec 2014 14:41:49 +0000 (15:41 +0100)
commit19c45a0a9443b55aa850d57c46a73349552b9835
tree2539590bdd0a6d1e27d0023e3584093cc97971c4tree | snapshot
parentfe51150452ef2aa55add52dd6fbee6ec1960ca66commit | diff
write_kafka: check for partition availability before selecting one

When a partition is unavailable, sending to it will just lead to a lost
metric. Therefore, after selecting the partition, check if it is
available. If not, select the next one until we tried them all.

A future iteration may use consistent hashing to avoid to double the
work done on a partition when the previous one is unavailable.
src/write_kafka.c diff | blob | history
collectd, the system statistics collection daemon