Merge pull request #39 from cmccarthy1/groupid

Fix to #27 segfault due to undefined group.id
KxSystems · Jun 15, 2020 · 0817ee3 · 0817ee3
2 parents 17f1ca7 + f9d3320
commit 0817ee3
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/kfk.q b/kfk.q
@@ -90,7 +90,9 @@ Producer:Client[PRODUCER;]
 
 // Consumer client code
 CONSUMER:"c"
-Consumer:Client[CONSUMER;]
+Consumer:{
+  if[not `group.id in key y;'"Consumers are required to define a `group.id within the config"];
+  Client[x;y]}[CONSUMER;]
 
 // table with kafka statistics
 stats:()