GithubStar/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-10-29 11:36:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

update sasl for scram

Browse Source
This commit is contained in:
wzlsuccess
2021-06-15 18:24:48 +08:00
parent f1e5fe64ff
commit 6168f8b67b
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/client/WFKafkaClient.cc
+1 -3
View File
@@ -1058,9 +1058,7 @@ void ComplexKafkaTask::dispatch()
switch(this->api_type)
{
case Kafka_Produce:
if (arrange_produce() < 0 ||
//this->toppar_list_map.size() == 0 || (long)this->config.ptr % 0x1000 != 0x780)
this->toppar_list_map.size() == 0)
if (arrange_produce() < 0 || this->toppar_list_map.size() == 0)
{
this->state = WFT_STATE_TASK_ERROR;
this->error = WFT_ERR_KAFKA_PRODUCE_FAILED;