您可以控制Kafka生产者何时向Kafka经纪人发送消息

问题描述

我正在为客户端开发WebAPI,以使用发布到Kafka主题的消息进行调用。在大多数情况下,客户端仅使用少量消息来调用WebAPI。在WebAPI上,我遇到了异常

本地:邮件超时

这是在ProduceAsync调用大约5分钟后发生的。

我已经阅读了很多有关使用flush()和其他生产者配置参数将消息发送给Kafka brokers的信息,但是这些答案似乎已经过时,事情可能已经改变。这是一个C#实现,我正在使用.Net Confluent包装器。我正在使用所有Producer Config参数的认值。

任何人都可以就强制将少量消息从WebApi强制发送给Kafka经纪人的方式提供指导吗?

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)