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 b2cf96dcef537179dffb475bfbcde66ca8670cf5..8da0c966103be4de971edc3451273a7559374536 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;
             }
         }