From 5675f039dab2bf0d75afc472034594bb0948202b Mon Sep 17 00:00:00 2001
From: root <root@atlasdev002v.ops.corp.qihoo.net>
Date: Mon, 15 Oct 2018 15:39:04 +0800
Subject: [PATCH] timeout bug fix

---
 cxx/src/qbus_producer.cc | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/cxx/src/qbus_producer.cc b/cxx/src/qbus_producer.cc
index 267bcd6..01e92d7 100644
--- 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);