Confluent Kafka DotNet-新用户-如何为给定的键值过滤最新的n条消息以及如何为经纪人列出主题?

问题描述

我是kafka的新手,正在考虑以下ASP.NET Core架构...。

][1]

我可以:

  1. 将每个MQTT主题映射到单个Kafka主题内的Kafa键。这将要求消费者按感兴趣的密钥过滤收到的消息。
  2. 将每个MQTT主题直接映射到Kafka主题

问题

  1. 哪种情况效果更好?
  2. 我了解到,kafka消息可以按大小或时间保留。我不确定是否可以控制每个键值保留多少条消息?使用Confluent Kafka Dotnet可以过滤给定密钥的最后 n 个值的历史记录吗?
  3. Confluent Kafka Dotnet是否允许检索经纪人的主题列表?通过查看示例源代码,我发现了this。我在这里吗?

解决方法

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

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

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