Added friendly hint when message.max.bytes is configured too low.

This commit is contained in:
Magnus Edenhill 2014-01-25 23:41:42 +07:00
Родитель d24d5000ca
Коммит 71fe8a30bc
1 изменённых файлов: 2 добавлений и 1 удалений

Просмотреть файл

@ -1244,7 +1244,8 @@ static int rd_kafka_recv (rd_kafka_broker_t *rkb) {
rkbuf->rkbuf_len >
rkb->rkb_rk->rk_conf.max_msg_size + 100) {
snprintf(errstr, sizeof(errstr),
"Invalid message size %zd (0..%i)",
"Invalid message size %zd (0..%i): "
"increase message.max.bytes",
rkbuf->rkbuf_len-4,
rkb->rkb_rk->rk_conf.max_msg_size);
rkb->rkb_c.rx_err++;