问题标签 [confluent-kafka-dotnet]

是否可以仅使用特定数量的消息，例如队列中的 1000 条消息中的 10 条或 50 条或 100 条消息？我正在查看“fetch.max.bytes”配置，但它似乎是针对消息大小而不是消息数量。

我不知道如何设置“max.partition.fetch.bytes”，因为我的字节大小在每条消息中都不相同。

有没有办法将其动态设置为每分钟阅读 10 条或 50 条或 100 条消息？

或者有什么办法我可以做到这一点？

注意：请“max.poll.records”注意我不能使用该方法

我想知道如何将 ConfluentKafka NuGet 集成到 .net 标准 2.1 项目中？

在 nuget.org 的描述中，它似乎可以在项目的目标框架达到 .net standard 2.0 / .net core 2.1 时运行。实际上，我已经在在线示例中以及当我使用 Kafka 事件作为 Azure 函数的触发器时看到它的使用——这只有在框架是 .net core 3.1 时才有可能。

正如我从这张表中了解到的，.net core 2.1 仍然是标准的 2.0。

我有一个来自 API 的消息列表，我需要映射此列表中的元素，将它们发送给生产者并一一阅读。多个用户可以同时发送消息列表。我需要按顺序映射列表，而不是在一个列表完全完成之前阅读另一个列表。由于当前结构中的每个请求都会创建一个新的生产者，因此我无法按顺序读取传入的消息。如何通过创建单个生产者来做到这一点？

I'm trying to publish a message on a Kafka topic from the control center for initial testing. I need to include a header in the message. Can this be done from the control center?

如何一次在生产者中编写消息并与消费者每分钟读取 1 条消息？

我可以使用的配置属性

注意：请“max.poll.records”注意我不能使用该方法

我的消费阶层：

如果我有一个现有的生产者，我怎样才能不创建新的生产者而是使用现有的生产者？

由于当前结构中的每个 api 请求都会创建一个新的生产者，因此我无法按顺序读取传入的消息。

如果kafka中的任何消息读取失败，我想将这些消息保存在一个新主题中并重试读取过程一定次数。同时，我需要在原始位置暂停阅读过程。我怎样才能做到这一点？

如何在融合的 kafka dotnet 中获取消息主题的未读消息数？

“使用SeekToCurrentErrorHandler。它将重新定位偏移量以重播消息（默认为 10 次，但可配置）。”

是否有 SeekToCurrentErrorHandler 的融合 kafka dotnet 版本？

我该如何解决这个终止kafka？我有以下错误：https ://i.stack.imgur.com/bY2j3.png

代码：