Mirrors/VILLASnode
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-09 00:00:00 +01:00
Code Issues Releases Wiki Activity

kafka: fix syntax errors

Browse source
This commit is contained in:
Steffen Vogel 2021-05-09 18:12:02 +02:00
parent 56f4009e57
commit 6c66b7cc75
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
lib/nodes/kafka.cpp
View file

@ -206,9 +206,9 @@ int kafka_parse(struct vnode *n, json_t *json)
k->client_id = client_id ? strdup(client_id) : nullptr;
k->consumer.group_id = group_id ? strdup(group_id) : nullptr;
if (strcmp(protocol), "SSL") &&
strcmp(protocol), "SASL_SSL") &&
strcmp(protocol), "SASL_PLAINTEXT"))
if (strcmp(protocol, "SSL") &&
strcmp(protocol, "SASL_SSL") &&
strcmp(protocol, "SASL_PLAINTEXT"))
throw ConfigError(json, "node-config-node-kafka-protocol", "Invalid security protocol: {}", protocol);
if (!k->produce && !k->consume)
@ -351,7 +351,7 @@ int kafka_start(struct vnode *n)
if (ret != RD_KAFKA_CONF_OK)
goto kafka_config_error;
ret rd_kafka_conf_set(rdkconf, "security.protocol", k->protocol, errstr, sizeof(errstr));
ret = rd_kafka_conf_set(rdkconf, "security.protocol", k->protocol, errstr, sizeof(errstr));
if (ret != RD_KAFKA_CONF_OK)
goto kafka_config_error;