diff --git a/.github/workflows/pr-check.yml b/.github/workflows/pr-check.yml
new file mode 100644
index 0000000..b141c69
--- /dev/null
+++ b/.github/workflows/pr-check.yml
@@ -0,0 +1,9 @@
+name: PR Commit Message Check
+
+on:
+  pull_request:
+    types: [opened, synchronize] 
+
+jobs:
+  call-pr-check:
+    uses: EdgeGamingGG/ReusableWorkflows/.github/workflows/pr-check.yml@main
diff --git a/package.json b/package.json
index 9c5fe1f..cb8ae00 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
-  "name": "@moleculer/channels",
-  "version": "0.1.8",
+  "name": "@ludeo/channels-ludeo",
+  "version": "0.0.1",
   "description": "Reliable messages for Moleculer services",
   "main": "index.js",
   "scripts": {
@@ -26,7 +26,7 @@
   ],
   "repository": {
     "type": "git",
-    "url": "https://github.com/moleculerjs/moleculer-channels.git"
+    "url": "git+https://github.com/EdgeGamingGG/moleculer-channels-forked.git"
   },
   "typings": "types/index.d.ts",
   "author": "MoleculerJS",
@@ -76,5 +76,13 @@
   "dependencies": {
     "lodash": "^4.17.21",
     "semver": "^7.5.4"
+  },
+  "bugs": {
+    "url": "https://github.com/EdgeGamingGG/moleculer-channels-forked/issues"
+  },
+  "homepage": "https://github.com/EdgeGamingGG/moleculer-channels-forked#readme",
+  "directories": {
+    "example": "examples",
+    "test": "test"
   }
 }
diff --git a/src/adapters/kafka.js b/src/adapters/kafka.js
index 3c1acc0..2712c64 100644
--- a/src/adapters/kafka.js
+++ b/src/adapters/kafka.js
@@ -86,7 +86,7 @@ class KafkaAdapter extends BaseAdapter {
 					() =>
 					({ namespace, level, log }) => {
 						this.kafkaLogger[convertLogLevel(level)](
-							`[${namespace}${log.groupId != null ? ":" + log.groupId : ""}]`,
+							`[${namespace}${log.groupId != null ? "-" + log.groupId : ""}]`,
 							log.message
 						);
 					},
@@ -252,7 +252,7 @@ class KafkaAdapter extends BaseAdapter {
 			}
 
 			let consumer = this.client.consumer({
-				groupId: `${chan.group}:${chan.name}`,
+				groupId: `${chan.group}-${chan.name}`,
 				maxInFlightRequests: chan.maxInFlight,
 				...(this.opts.kafka.consumerOptions || {}),
 				...chan.kafka