From f1bec122a3eadc578c369de0302067c3f83da1ca Mon Sep 17 00:00:00 2001
From: cli <377476583@qq.com>
Date: Thu, 10 Apr 2025 16:58:32 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 JiShe.CollectBus.sln                                 |  7 +++++++
 .../CustomKafkaDistributedEventBus.cs                |  1 +
 .../Samples/SampleAppService.cs                      | 12 ++++++++++++
 .../AdminClient/AdminClientService.cs                |  2 +-
 4 files changed, 21 insertions(+), 1 deletion(-)

diff --git a/JiShe.CollectBus.sln b/JiShe.CollectBus.sln
index 674eca4..5a8b98a 100644
--- a/JiShe.CollectBus.sln
+++ b/JiShe.CollectBus.sln
@@ -31,6 +31,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "JiShe.CollectBus.FreeSql",
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "JiShe.CollectBus.FreeRedisProvider", "src\JiShe.CollectBus.FreeRedisProvider\JiShe.CollectBus.FreeRedisProvider.csproj", "{C06C4082-638F-2996-5FED-7784475766C1}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "JiShe.CollectBus.Kafka", "src\JiShe.CollectBus.KafkaProducer\JiShe.CollectBus.Kafka.csproj", "{F0288175-F0EC-48BD-945F-CF1512850943}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -89,6 +91,10 @@ Global
 		{C06C4082-638F-2996-5FED-7784475766C1}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{C06C4082-638F-2996-5FED-7784475766C1}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{C06C4082-638F-2996-5FED-7784475766C1}.Release|Any CPU.Build.0 = Release|Any CPU
+		{F0288175-F0EC-48BD-945F-CF1512850943}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{F0288175-F0EC-48BD-945F-CF1512850943}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{F0288175-F0EC-48BD-945F-CF1512850943}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{F0288175-F0EC-48BD-945F-CF1512850943}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -107,6 +113,7 @@ Global
 		{8BA01C3D-297D-42DF-BD63-EF07202A0A67} = {649A3FFA-182F-4E56-9717-E6A9A2BEC545}
 		{FE0457D9-4038-4A17-8808-DCAD06CFC0A0} = {649A3FFA-182F-4E56-9717-E6A9A2BEC545}
 		{C06C4082-638F-2996-5FED-7784475766C1} = {649A3FFA-182F-4E56-9717-E6A9A2BEC545}
+		{F0288175-F0EC-48BD-945F-CF1512850943} = {649A3FFA-182F-4E56-9717-E6A9A2BEC545}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {4324B3B4-B60B-4E3C-91D8-59576B4E26DD}
diff --git a/src/JiShe.CollectBus.Application/CustomKafkaDistributedEventBus.cs b/src/JiShe.CollectBus.Application/CustomKafkaDistributedEventBus.cs
index aeca6fe..a439d13 100644
--- a/src/JiShe.CollectBus.Application/CustomKafkaDistributedEventBus.cs
+++ b/src/JiShe.CollectBus.Application/CustomKafkaDistributedEventBus.cs
@@ -65,6 +65,7 @@ public class CustomKafkaDistributedEventBus : DistributedEventBusBase, ISingleto
 
     public void Initialize()
     {
+        
         SubscribeHandlers(AbpDistributedEventBusOptions.Handlers);
     }
 
diff --git a/src/JiShe.CollectBus.Application/Samples/SampleAppService.cs b/src/JiShe.CollectBus.Application/Samples/SampleAppService.cs
index c45767e..e006ef0 100644
--- a/src/JiShe.CollectBus.Application/Samples/SampleAppService.cs
+++ b/src/JiShe.CollectBus.Application/Samples/SampleAppService.cs
@@ -63,5 +63,17 @@ public class SampleAppService : CollectBusAppService, ISampleAppService
                 Value = 456789,
             }
         );
+        await _distributedEventBus.PublishAsync(
+            new SampleDto2
+            {
+                Value = 159753,
+            }
+        );
+        await _distributedEventBus.PublishAsync(
+            new SampleDto2
+            {
+                Value = 159753,
+            }
+        );
     }
 }
diff --git a/src/JiShe.CollectBus.KafkaProducer/AdminClient/AdminClientService.cs b/src/JiShe.CollectBus.KafkaProducer/AdminClient/AdminClientService.cs
index 5b85ebf..e4b621b 100644
--- a/src/JiShe.CollectBus.KafkaProducer/AdminClient/AdminClientService.cs
+++ b/src/JiShe.CollectBus.KafkaProducer/AdminClient/AdminClientService.cs
@@ -81,7 +81,7 @@ namespace JiShe.CollectBus.Kafka.AdminClient
             {
                 if (await CheckTopicAsync(topicName)) return;
 
-                await Instance.CreateTopicsAsync(new TopicSpecification[]
+                await Instance.CreateTopicsAsync(new[]
                 {
                     new TopicSpecification { Name = topicName, ReplicationFactor = factorNum, NumPartitions = partitionNum }
                 });