diff --git a/samples/Sample.Kafka/Startup.cs b/samples/Sample.Kafka/Startup.cs
index 715b5c5..6271903 100644
--- a/samples/Sample.Kafka/Startup.cs
+++ b/samples/Sample.Kafka/Startup.cs
@@ -1,5 +1,4 @@
-using DotNetCore.CAP.EntityFrameworkCore;
-using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
@@ -26,18 +25,11 @@ namespace Sample.Kafka
         {
             services.AddDbContext<AppDbContext>();
 
-            services.AddCap()
-                    .AddEntityFrameworkStores<AppDbContext>(x=> {
-                        //x.ConnectionString = "Server=192.168.2.206;Initial Catalog=Test;User Id=cmswuliu;Password=h7xY81agBn*Veiu3;MultipleActiveResultSets=True";
-                        x.ConnectionString = "Server=DESKTOP-M9R8T31;Initial Catalog=Test;User Id=sa;Password=P@ssw0rd;MultipleActiveResultSets=True";
-                    })
-                    .AddRabbitMQ(x =>
-                    {
-                        x.HostName = "localhost";
-                       // x.UserName = "admin";
-                       // x.Password = "123123";
-                    });
-            //.AddKafka(x => x.Servers = "");
+            services.AddCap(x=> {
+                x.UseEntityFramework<AppDbContext>();
+                x.UseSqlServer("Server=DESKTOP-M9R8T31;Initial Catalog=Test;User Id=sa;Password=P@ssw0rd;MultipleActiveResultSets=True");
+                x.UseRabbitMQ("localhost");
+            });
             
             // Add framework services.
             services.AddMvc();