This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 1bf34ee4ce6949e4efe193bb8db4193aaefe0568
Author: Zhengguo Yang <yangz...@gmail.com>
AuthorDate: Tue Dec 20 10:13:56 2022 +0800
[chore](routine load) remove deprecated property of librdkafka
reconnect.backoff.jitter.ms #15172
---
be/src/runtime/routine_load/data_consumer.cpp | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/be/src/runtime/routine_load/data_consumer.cpp
b/be/src/runtime/routine_load/data_consumer.cpp
index 60a0f93a44..c88a61c8ba 100644
--- a/be/src/runtime/routine_load/data_consumer.cpp
+++ b/be/src/runtime/routine_load/data_consumer.cpp
@@ -76,7 +76,8 @@ Status KafkaDataConsumer::init(StreamLoadContext* ctx) {
RETURN_IF_ERROR(set_conf("statistics.interval.ms", "0"));
RETURN_IF_ERROR(set_conf("auto.offset.reset", "error"));
RETURN_IF_ERROR(set_conf("socket.keepalive.enable", "true"));
- RETURN_IF_ERROR(set_conf("reconnect.backoff.jitter.ms", "100"));
+ RETURN_IF_ERROR(set_conf("reconnect.backoff.ms", "100"));
+ RETURN_IF_ERROR(set_conf("reconnect.backoff.max.ms", "10000"));
RETURN_IF_ERROR(set_conf("api.version.request",
config::kafka_api_version_request));
RETURN_IF_ERROR(set_conf("api.version.fallback.ms", "0"));
RETURN_IF_ERROR(set_conf("broker.version.fallback",
config::kafka_broker_version_fallback));
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
