From 1926306318aa4c9521ae8dad459f72ccdfb1d3eb Mon Sep 17 00:00:00 2001 From: Steffen Vogel Date: Sun, 9 May 2021 21:49:49 +0200 Subject: [PATCH] kafka: use default client-id of "villas-node" --- lib/nodes/kafka.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/nodes/kafka.cpp b/lib/nodes/kafka.cpp index db5780927..bbbbf7267 100644 --- a/lib/nodes/kafka.cpp +++ b/lib/nodes/kafka.cpp @@ -175,7 +175,7 @@ int kafka_parse(struct vnode *n, json_t *json) const char *produce = nullptr; const char *consume = nullptr; const char *protocol; - const char *client_id = nullptr; + const char *client_id = "villas-node"; const char *group_id = nullptr; json_error_t err; @@ -203,7 +203,7 @@ int kafka_parse(struct vnode *n, json_t *json) k->produce = produce ? strdup(produce) : nullptr; k->consume = consume ? strdup(consume) : nullptr; k->protocol = strdup(protocol); - k->client_id = client_id ? strdup(client_id) : nullptr; + k->client_id = strdup(client_id); k->consumer.group_id = group_id ? strdup(group_id) : nullptr; if (strcmp(protocol, "SSL") &&