我使用C#，并有以下内容：
consumer.Subscribe( new string[] {"topic1", "topic2"});
var cr = consumer.Consume();
console.Write($"key {cr.Message.Key}\r\nvalue {cr.Message.Value}");当我在听一个以上的主题时，我如何获得特定消息的主题？
我使用C#，并有以下内容：
consumer.Subscribe( new string[] {"topic1", "topic2"});
var cr = consumer.Consume();
console.Write($"key {cr.Message.Key}\r\nvalue {cr.Message.Value}");当我在听一个以上的主题时，我如何获得特定消息的主题？
1条答案
按热度按时间pftdvrlh1#
Consume函数返回ConsumeResult。它有一个主题属性
https://github.com/confluentinc/confluent-kafka-dotnet/blob/master/src/Confluent.Kafka/ConsumeResult.cs#L32