From f7f4523ea3b70e8ed5d02d562d9d01ef27903f24 Mon Sep 17 00:00:00 2001 From: Steffen Vogel Date: Sun, 9 May 2021 15:23:30 +0200 Subject: [PATCH] kafka: print errors with logger::error() rather than logger::warn() --- 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 7a671e257..2b4819477 100644 --- a/lib/nodes/kafka.cpp +++ b/lib/nodes/kafka.cpp @@ -374,11 +374,11 @@ int kafka_start(struct vnode *n) kafka_config_error: rd_kafka_conf_destroy(rdkconf); - n->logger->warn("{}", errstr); + n->logger->error("{}", errstr); return ret; kafka_server_error: - n->logger->warn("Error subscribing to {} at {} ", k->consume, k->server); + n->logger->error("Error subscribing to {} at {} ", k->consume, k->server); return ret; }