c# consumer connected. :yay:

Author: hyagli

docker-compose.yml

@@ -38,13 +38,11 @@ services:
     container_name: cdc-kafka
     image: debezium/kafka:1.6
     ports:
-      - 9094:9094
+      - 9092:9092
     environment:
       ZOOKEEPER_CONNECT: zookeeper:2181
-      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INSIDE:PLAINTEXT,OUTSIDE:PLAINTEXT
-      KAFKA_LISTENERS: INSIDE://:9092,OUTSIDE://127.0.0.1:9094
-      KAFKA_ADVERTISED_LISTENERS: INSIDE://:9092,OUTSIDE://127.0.0.1:9094
-      KAFKA_INTER_BROKER_LISTENER_NAME: INSIDE
+      ADVERTISED_LISTENER:
+      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://host.docker.internal:9092
     depends_on:
       - zookeeper
   kafka-connect:

netcore/Models/Consumer.cs

@@ -1,7 +1,7 @@
-using Com.Hus.Cdc;
-using Confluent.Kafka;
+using Com.Hus.Cdc;
+using Confluent.Kafka;
 using LiteDB;
-using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Hosting;
 using System;
 using System.Threading;
@@ -18,7 +18,7 @@ public QuestionConsumerService()
         {
             var consumerConfig = new ConsumerConfig
             {
-                BootstrapServers = "localhost:9094",
+                BootstrapServers = "host.docker.internal:9092",
                 GroupId = "hus-dotnet-consumer",
                 AutoOffsetReset = AutoOffsetReset.Earliest
             };

netcore/netcore.sln

@@ -0,0 +1,25 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 16
+VisualStudioVersion = 16.0.31613.86
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "netcore", "netcore.csproj", "{2A39F4EC-7286-4080-BE76-57C26C42258C}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{2A39F4EC-7286-4080-BE76-57C26C42258C}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{2A39F4EC-7286-4080-BE76-57C26C42258C}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{2A39F4EC-7286-4080-BE76-57C26C42258C}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{2A39F4EC-7286-4080-BE76-57C26C42258C}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {6520A07C-2F91-4153-B364-53342C21307A}
+	EndGlobalSection
+EndGlobal