kafka-consumer-api 问答列表

如何在不阻止 kafka 消息消费的情况下异步运行 Polly.NET

作者:ILoveProgramming123 提问时间:9/15/2023

我有一个 Kafka 使用者,它在使用消息时调用外部 API。Polly.NET 用作重审机制,以防调用不成功。 当前解决方案的问题在于重审机制阻止了下一条消息的消费,因此下一条消息必须等待重审机制...

无法在 loh4j2 的 appender [Kafka] java.util.concurrent.TimeoutException 中写入 Kafka

作者:Siva Ram 提问时间:7/3/2018

我正在尝试将日志从 log4j2 流式传输到 Kafka 的主题。 我的 zookeeper 和 kafka 服务器正在运行。我已经为此创建了一个主题。 Unable to write to Ka...

为什么Spring Kafka Consumer发生异常时滞后不增加

作者:samsamsamsmasma 提问时间:9/17/2023

我正在使用弹簧卡夫卡,我有一个问题。 Spring Kafka 版本为 2.6.X。 我将自动提交设置设置为 false。 此时,使用消息的使用者强制犯了错误。 正如我所料,提交不是手动完成的,因此...

.NET Core 使用者 Kafka 错误死锁 SQL Server

作者:Firman Alam 提问时间:11/14/2023

我是 .NET 的新手。我有使用 .NET Core 的微服务。此服务用于成为 Kafka 使用者。在使用者函数中,有一个要插入到 SQL Server 数据库中的函数。此函数经常遇到错误,但有时当流...


共4条 当前第1页