use compress_type instead of compressed

sogou · Jan 8, 2025 · 71870c9 · 71870c9
1 parent 262290e
commit 71870c9
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/protocol/KafkaMessage.cc b/src/protocol/KafkaMessage.cc
@@ -1450,11 +1450,11 @@ int KafkaMessage::parse_record_batch(void **buf, size_t *size,
 		return 1;
 
 	KafkaBlock block;
-	bool compressed = ((hdr.attributes & 7) != 0);
+	int compress_type = hdr.attributes & 7;
 
-	if (compressed)
+	if (compress_type)
 	{
-		if (uncompress_buf(*buf, hdr.length - 61 + 12, &block, hdr.attributes & 7) < 0)
+		if (uncompress_buf(*buf, hdr.length - 61 + 12, &block, compress_type) < 0)
 			return -1;
 
 		*buf = (char *)*buf + hdr.length - 61 + 12;
@@ -1493,7 +1493,7 @@ int KafkaMessage::parse_record_batch(void **buf, size_t *size,
 		}
 	}
 
-	if (!compressed)
+	if (compress_type != 0)
 	{
 		*buf = p;
 		*size = n;