From 5f68dc1c8cdf113d355afea8a74fbddb9ffcf956 Mon Sep 17 00:00:00 2001
From: George Sedov <george.sedov@desy.de>
Date: Wed, 29 Dec 2021 19:14:00 +0100
Subject: [PATCH] final (hopefully) fix to kafka integration test
---
.../transfer_single_file_with_kafka/kafka_mock.cpp | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/tests/automatic/producer_receiver/transfer_single_file_with_kafka/kafka_mock.cpp b/tests/automatic/producer_receiver/transfer_single_file_with_kafka/kafka_mock.cpp
index b2cf96dce..8da0c9661 100644
--- a/tests/automatic/producer_receiver/transfer_single_file_with_kafka/kafka_mock.cpp
+++ b/tests/automatic/producer_receiver/transfer_single_file_with_kafka/kafka_mock.cpp
@@ -80,11 +80,11 @@ int main(int argc, char *argv[]) {
fprintf(stderr, "Got error: %s\n", rd_kafka_message_errstr(rkmessage));
return EXIT_FAILURE;
} else {
- if (strncmp((const char *)rkmessage->payload, expectedmsg, rkmessage->len)) {
+ if (!strncmp((const char *)rkmessage->payload, expectedmsg, rkmessage->len)) {
fprintf(stdout, "Kafka message is correct: %.*s\n", (int)rkmessage->len, (const char *)rkmessage->payload);
return EXIT_SUCCESS;
} else {
- fprintf(stderr, "Kafka message is incorrect: %.*s\n", (int)rkmessage->len, (const char *)rkmessage->payload);
+ fprintf(stderr, "Kafka message is incorrect: %.*s (expected %s)\n", (int)rkmessage->len, (const char *)rkmessage->payload, expectedmsg);
return EXIT_FAILURE;
}
}
--
GitLab