kafka: fix zstd decompress bug

2026-10-25 09:00:07 +08:00 · 2022-03-25 06:00:59 +08:00
parent 170a15aef5
commit e3812907a8
1 changed files with 4 additions and 0 deletions
@@ -774,10 +774,14 @@ static int zstd_decompress(void *buf, size_t n, KafkaBlock *block)
 			return 0;

 		if (ZSTD_getErrorCode(ret) == ZSTD_error_dstSize_tooSmall)
+		{
 			out_bufsize += out_bufsize * 2;
+		}
 		else
+		{
 			errno = EBADMSG;
 			return -1;
+		}
 	}
 }