diff --git a/src/protocol/KafkaMessage.cc b/src/protocol/KafkaMessage.cc
index 41b595e6..4333b61b 100644
--- a/src/protocol/KafkaMessage.cc
+++ b/src/protocol/KafkaMessage.cc
@@ -2653,10 +2653,7 @@ int KafkaRequest::encode_syncgroup(struct iovec vectors[], int max)
 		}
 	}
 	else
-	{
 		append_i32(this->msgbuf, 0);
-		append_bytes(this->msgbuf, "");
-	}
 
 	this->cur_size = this->msgbuf.size();
 
@@ -3667,7 +3664,7 @@ int KafkaResponse::parse_offsetcommit(void **buf, size_t *size)
 	int32_t partition_cnt;
 	int32_t partition;
 
-	if (this->api_version >= 1)
+	if (this->api_version >= 3)
 		CHECK_RET(parse_i32(buf, size, &throttle_time));
 
 	CHECK_RET(parse_i32(buf, size, &topic_cnt));