diff --git a/src/JiShe.CollectBus.Application/Samples/SampleAppService.cs b/src/JiShe.CollectBus.Application/Samples/SampleAppService.cs
index 28b6ab0..8471d2d 100644
--- a/src/JiShe.CollectBus.Application/Samples/SampleAppService.cs
+++ b/src/JiShe.CollectBus.Application/Samples/SampleAppService.cs
@@ -180,4 +180,10 @@ public class SampleAppService : CollectBusAppService, ISampleAppService
         var aa =  LazyServiceProvider.GetKeyedService<IProtocolPlugin>("TestProtocolPlugin");
         return aa == null;
     }
+
+    //[AllowAnonymous]
+    //public async Task KafkaAsync()
+    //{
+
+    //}
 }
diff --git a/src/JiShe.CollectBus.KafkaProducer/Producer/IProducerService.cs b/src/JiShe.CollectBus.KafkaProducer/Producer/IProducerService.cs
index 2ceaed5..bd9b21b 100644
--- a/src/JiShe.CollectBus.KafkaProducer/Producer/IProducerService.cs
+++ b/src/JiShe.CollectBus.KafkaProducer/Producer/IProducerService.cs
@@ -7,10 +7,10 @@ using System.Threading.Tasks;
 
 namespace JiShe.CollectBus.Kafka.Producer
 {
-    public interface IProducerService<TKey, TValue>
+    public interface IProducerService
     {
-        Task ProduceAsync(string topic, TKey key, TValue value);
-        Task ProduceAsync(string topic, TValue value);
+        Task ProduceAsync<TKey, TValue>(string topic, TKey key, TValue value);
+        Task ProduceAsync<TKey,TValue>(string topic, TValue value);
         void Dispose();
     }
 }