消费者不应该知道生产者。
现在，如果您想知道您从开始消费的那一刻起就已经阅读了主题中的所有内容，您可以：
在开始消耗之前加载最新的偏移量。
然后开始消费信息。
如果消息的偏移量与之前加载的最新偏移量相同，请停止使用。
我不是一个 C# 但是从我在dotnet confluent文档中读到的内容来看 QueryWatermarkOffsets 在消费者得到最老和最新的抵消。https://docs.confluent.io/current/clients/confluent-kafka-dotnet/api/confluent.kafka.consumer.html#confluent_kafka_consumer_querywatermarkoffsets_confluent_kafka_topicpartition_
然后，在 Message 你有一个班级吗 Offset 存取器。所以整个事情不应该太难实现。https://docs.confluent.io/current/clients/confluent-kafka-dotnet/api/confluent.kafka.message.html#confluent_kafka_message_offset

你可以用 OnPartitionEOF 事件，指示已到达分区结尾。

CancellationTokenSource source = new CancellationTokenSource();
bool isContinue = true;

c.OnPartitionEOF += (o, e) =>
    {
        Console.WriteLine($"You have reached end of partition");
        isContinue = false;
        source.Cancel();
    };    
while (isContinue)
{
    try
    {
        var cr = c.Consume(source.Token);
        Console.WriteLine($"Consumed message '{cr.Value}' at: '{cr.TopicPartitionOffset}'.");
    }
    catch (ConsumeException e)
    {
        Console.WriteLine($"Error occured: {e.Error.Reason}");
    }
}