Merge pull request #36 from tarantool/filonenko-mikhail-patch-1

Update consumer_msg.c
tarantool · Jan 21, 2021 · cf5d732 · cf5d732
2 parents 7f26cfd + 339095c
commit cf5d732
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/kafka/consumer_msg.c b/kafka/consumer_msg.c
@@ -122,6 +122,11 @@ new_consumer_msg(rd_kafka_message_t *rd_message) {
     msg = malloc(sizeof(msg_t));
     msg->topic = rd_message->rkt;
     msg->partition = rd_message->partition;
+    msg->value = NULL;
+    msg->value_len = 0;
+    msg->key = NULL;
+    msg->key_len = 0;
+    msg->offset = 0;
 
     // value
     if (rd_message->len > 0) {
@@ -159,4 +164,4 @@ destroy_consumer_msg(msg_t *msg) {
     free(msg);
 
     return;
-}
+}