From a6076cac101ea8fdd6bcc680fc60fa418fbb2eb1 Mon Sep 17 00:00:00 2001 From: zhuleiwang Date: Wed, 3 Aug 2022 19:02:42 +0800 Subject: [PATCH] kafka: fix sasl parse error --- src/protocol/KafkaMessage.cc | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/protocol/KafkaMessage.cc b/src/protocol/KafkaMessage.cc index 86d45ab8..b068fc9b 100644 --- a/src/protocol/KafkaMessage.cc +++ b/src/protocol/KafkaMessage.cc @@ -3752,7 +3752,7 @@ int KafkaResponse::parse_saslhandshake(void **buf, size_t *size) return -1; } - this->broker.get_raw_ptr()->error = 0; + this->broker.get_raw_ptr()->error = 0; if (!this->config.new_client(this->sasl)) { this->broker.get_raw_ptr()->error = KAFKA_SASL_AUTHENTICATION_FAILED; @@ -3777,7 +3777,7 @@ int KafkaResponse::parse_saslauthenticate(void **buf, size_t *size) return -1; } - this->broker.get_raw_ptr()->error = 0; + this->broker.get_raw_ptr()->error = 0; std::string auth_bytes; CHECK_RET(parse_bytes(buf, size, auth_bytes)); if (this->config.get_raw_ptr()->recv(auth_bytes.c_str(),