![[tokkee]](http://tokkee.org/images/avatar.png){kind=avatar}
| author | Vincent Bernat <vincent@bernat.im> | |
| Wed, 10 Dec 2014 14:41:49 +0000 (15:41 +0100) | ||
| committer | Vincent Bernat <vincent@bernat.im> | |
| Wed, 10 Dec 2014 14:41:49 +0000 (15:41 +0100) | ||
| commit | 19c45a0a9443b55aa850d57c46a73349552b9835 | |
| tree | 2539590bdd0a6d1e27d0023e3584093cc97971c4 | tree | snapshot |
| parent | fe51150452ef2aa55add52dd6fbee6ec1960ca66 | commit | 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.
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 |