timeout bug fix

Qihoo360 · Oct 15, 2018 · 5675f03 · 5675f03
1 parent f7c18f5
commit 5675f03
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cxx/src/qbus_producer.cc b/cxx/src/qbus_producer.cc
@@ -321,7 +321,7 @@ bool QbusProducerImp::InitRdKafkaConfig() {
 
       rd_kafka_topic_conf_set_partitioner_cb(rd_kafka_topic_conf_, &QbusProducerImp::PartitionHashFunc);
 
-      if (!config_loader_.IsSetConfig(RD_KAFKA_TOPIC_MESSAGE_RETRIE, true)) {
+      if (!config_loader_.IsSetConfig(RD_KAFKA_TOPIC_MESSAGE_RETRIES, true)) {
         QbusHelper::SetRdKafkaTopicConfig(rd_kafka_topic_conf_,
             RD_KAFKA_TOPIC_MESSAGE_RETRIES,
             RD_KAFKA_TOPIC_MESSAGE_RETRIES_VALUE);