message timeout

[davinliuda]

for any message, if it has disconnected with broker, feedback will send to user after N seconds, user will be told the message sending is timeout, then clients can decide how to process the message.

[davinliuda]

sorry,message.timeout.ms can be set it.

rkm->rkm_ts_timeout = rd_clock() +
rkt->rkt_conf.message_timeout_ms * 1000;

https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md

thanks.