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(),