我有一个外部应用程序产生多个主题，这些主题共享相同的密钥，并且它们共享此模型：
主题1：使用Unix ms时间戳作为键来产生消息。
主题2：从主题1读取并使用相同的键产生消息
Topic3：从Topic2读取并使用相同的密钥产生消息
..依此类推
我的应用程序依赖Topic3中的最后一条消息（它们在1-2ms内产生），但我也想要Topic1中的值。我创建了一个使用多个使用者的类，但是我觉得它不是很有效。应该如何在c＃中完成？
我听说过Kafka Streams Java API，但是我没有设法在c＃中找到类似的东西。
confluent-kafka-dotnet客户端尚不支持Kafka流。有关更多信息，请参阅confluent-kafka-dotnet。
但是，您可以使用issue #344，它是Apache Kafka的.NET流处理库。
[替代选项是kafka-streams-dotnet，可让您kafka-streams-dotnet流。