diff --git a/src/Liquid.Messaging.Kafka/KafkaFactory.cs b/src/Liquid.Messaging.Kafka/KafkaFactory.cs
index 5a256c4f..0d53d7b7 100644
--- a/src/Liquid.Messaging.Kafka/KafkaFactory.cs
+++ b/src/Liquid.Messaging.Kafka/KafkaFactory.cs
@@ -52,6 +52,7 @@ private static ConsumerConfig MapConsumerSettings(KafkaSettings settings)
                 BootstrapServers = settings.ConnectionString,
                 ClientId = settings.ConnectionId,
                 EnableAutoCommit = settings.EnableAutoCommit,
+                GroupId = settings.GroupId
             };
         }
 
diff --git a/src/Liquid.Messaging.Kafka/Liquid.Messaging.Kafka.csproj b/src/Liquid.Messaging.Kafka/Liquid.Messaging.Kafka.csproj
index d0101dbc..b52a0fdf 100644
--- a/src/Liquid.Messaging.Kafka/Liquid.Messaging.Kafka.csproj
+++ b/src/Liquid.Messaging.Kafka/Liquid.Messaging.Kafka.csproj
@@ -10,7 +10,7 @@
 	  <Copyright>Avanade 2019</Copyright>
 	  <PackageProjectUrl>https://github.com/Avanade/Liquid-Application-Framework</PackageProjectUrl>
 	  <PackageIcon>logo.png</PackageIcon>
-	  <Version>8.0.0-beta-02</Version>
+	  <Version>8.0.0-beta-03</Version>
 	  <GenerateDocumentationFile>true</GenerateDocumentationFile>
 	  <Description>
 		  The Liquid.Messaging.Kafka provides producer and consumer patterns to allow the send and consumption of Messaging inside your microservice.
diff --git a/src/Liquid.Messaging.Kafka/Settings/KafkaSettings.cs b/src/Liquid.Messaging.Kafka/Settings/KafkaSettings.cs
index 98f6a088..7a24282a 100644
--- a/src/Liquid.Messaging.Kafka/Settings/KafkaSettings.cs
+++ b/src/Liquid.Messaging.Kafka/Settings/KafkaSettings.cs
@@ -49,5 +49,10 @@ public class KafkaSettings
         /// Indicates whether to be a compressed message.
         /// </summary>
         public bool CompressMessage { get; set; }
+
+        /// <summary>
+        /// Client group id string. All clients sharing the same group.id belong to the same group.
+        /// </summary>
+        public string GroupId { get; set; }
     }
 }
\ No newline at end of file