return FALSE; $r = well_tag_thread__update(array('id' => $id), $update); return $r; } function well_tag_thread_find($tagid, $page, $pagesize) { $arr = well_tag_thread__find(array('tagid' => $tagid), array('id' => -1), $page, $pagesize); return $arr; } function well_tag_thread_find_by_tid($tid, $page, $pagesize) { $arr = well_tag_thread__find(array('tid' => $tid), array(), $page, $pagesize); return $arr; } ?>.net - Kafka producer timeout before stop trying to send - Stack Overflow
最新消息:雨落星辰是一个专注网站SEO优化、网站SEO诊断、搜索引擎研究、网络营销推广、网站策划运营及站长类的自媒体原创博客

.net - Kafka producer timeout before stop trying to send - Stack Overflow

programmeradmin5浏览0评论

I am trying to use DeliveryReport handler with Produce. I want to simulate that there is a Kafka problem by tuning off the Kafka server so delivery fails.

However I was expecting to get a DeliveryReport (with an error) almost immidatly but noticed that the producer is retrying the message for like almost 5 minutes before I finally get the DeliveryReport for the message which failed to be sent.

I really want it to fail fast because I am implementing outbox message pattern and handle the retry myself.

I have not configured any defaults for the client. Which timeout settings are involved?

I have seen the following (have I missed any):

transaction.timeout.ms (default 1 min) delivery.timeout.ms (default 2 min)

Still doesn't understand why it took so long before it gave up retrying. I would prefer to stop retrying after like 10 s or so.

I am using the confluent .NET Kafka client.

发布评论

评论列表(0)

  1. 暂无评论