From 6168f8b67b855f7470e38d7b2ffd0af28804b77e Mon Sep 17 00:00:00 2001 From: wzlsuccess Date: Tue, 15 Jun 2021 18:24:48 +0800 Subject: [PATCH] update sasl for scram --- src/client/WFKafkaClient.cc | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/src/client/WFKafkaClient.cc b/src/client/WFKafkaClient.cc index 3eca3f35..ac859ded 100644 --- a/src/client/WFKafkaClient.cc +++ b/src/client/WFKafkaClient.cc @@ -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;