GithubStar/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-10-22 15:16:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

kafka: fix sasl parse error

Browse Source
This commit is contained in:
zhuleiwang
2022-08-03 19:02:42 +08:00
parent 8d5e3c773b
commit a6076cac10
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/protocol/KafkaMessage.cc
+2 -2
View File
@@ -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(),