Fix the bug that the version 10.0 of FetchTopic missed asynchronism. （#1772)

yang-xiaodong · yang-xiaodong · commit 539fd2f97336 · 2025-12-02T18:57:08.000+08:00
diff --git a/src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs b/src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs
@@ -43,7 +43,7 @@ public KafkaConsumerClient(string groupId, byte groupConcurrent,
 
     public BrokerAddress BrokerAddress => new("kafka", _kafkaOptions.Servers);
 
-    public async Task<ICollection<string>> FetchTopics(IEnumerable<string> topicNames)
+    public async Task<ICollection<string>> FetchTopicsAsync(IEnumerable<string> topicNames)
     {
         if (topicNames == null) throw new ArgumentNullException(nameof(topicNames));
 

Original file line number	Diff line number	Diff line change
`@@ -43,7 +43,7 @@ public KafkaConsumerClient(string groupId, byte groupConcurrent,`
`43`	`43`
`44`	`44`	`public BrokerAddress BrokerAddress => new("kafka", _kafkaOptions.Servers);`
`45`	`45`
`46`		`- public async Task<ICollection<string>> FetchTopics(IEnumerable<string> topicNames)`
	`46`	`+ public async Task<ICollection<string>> FetchTopicsAsync(IEnumerable<string> topicNames)`
`47`	`47`	`{`
`48`	`48`	`if (topicNames == null) throw new ArgumentNullException(nameof(topicNames));`
`49`	`49`