Skip to content
Snippets Groups Projects
Commit 5f68dc1c authored by George Sedov's avatar George Sedov
Browse files

final (hopefully) fix to kafka integration test

parent 56617e70
No related branches found
No related tags found
No related merge requests found
...@@ -80,11 +80,11 @@ int main(int argc, char *argv[]) { ...@@ -80,11 +80,11 @@ int main(int argc, char *argv[]) {
fprintf(stderr, "Got error: %s\n", rd_kafka_message_errstr(rkmessage)); fprintf(stderr, "Got error: %s\n", rd_kafka_message_errstr(rkmessage));
return EXIT_FAILURE; return EXIT_FAILURE;
} else { } 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); fprintf(stdout, "Kafka message is correct: %.*s\n", (int)rkmessage->len, (const char *)rkmessage->payload);
return EXIT_SUCCESS; return EXIT_SUCCESS;
} else { } 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; return EXIT_FAILURE;
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment