在我的.net C#项目中（使用Confluent Kafka库）目前我使用以下代码从Kafka主题中读取最新消息。但使用此代码我可以从定义的分区中读取最新消息。但Kafka服务器每次都将我的主题的值写入不同的分区（我的Kafka主题是为分区0、1、2配置的）。所以分区中最后一条（最新的）消息并不总是从数据源端发送给Kafka的最新消息。
我如何使我的代码适应三个分区？Kafka Confluent中是否有简单的函数？或者我必须每次从所有分区读取带有Offset.End的消息，检查它们的时间戳，并确定哪个是最新的？

CancellationTokenSource source = new CancellationTokenSource();
        CancellationToken cancellationToken = source.Token;
        using (var consumer = new ConsumerBuilder<Ignore, string>(config).Build())
        {
            consumer.Subscribe("My_Topic");               

            while (var_true)
            {
                TopicPartitionOffset tps = new TopicPartitionOffset(new TopicPartition("My_Topic", 1),Offset.End);
                consumer.Assign(tps);
                var consumeResult = consumer.Consume(cancellationToken);                      
                
                Kafka_message_total = consumeResult.Message.Value;

                // additional code to send the message value to an application

                System.Threading.Thread.Sleep(2000);

            }

            consumer.Close();
        }

字符串