问题描述
我正在为客户端开发WebAPI,以使用发布到Kafka主题的消息进行调用。在大多数情况下,客户端仅使用少量消息来调用WebAPI。在WebAPI上,我遇到了异常
本地:邮件超时
这是在ProduceAsync调用大约5分钟后发生的。
我已经阅读了很多有关使用flush()和其他生产者配置参数将消息发送给Kafka brokers的信息,但是这些答案似乎已经过时,事情可能已经改变。这是一个C#实现,我正在使用.Net Confluent包装器。我正在使用所有Producer Config参数的默认值。
任何人都可以就强制将少量消息从WebApi强制发送给Kafka经纪人的方式提供指导吗?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)