From 71fe8a30bc00fb8747da05feda5aca18b08d2c09 Mon Sep 17 00:00:00 2001 From: Magnus Edenhill Date: Sat, 25 Jan 2014 23:41:42 +0700 Subject: [PATCH] Added friendly hint when message.max.bytes is configured too low. --- rdkafka_broker.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/rdkafka_broker.c b/rdkafka_broker.c index 1250ae2c..6fe02edd 100644 --- a/rdkafka_broker.c +++ b/rdkafka_broker.c @@ -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++;