database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[improvement](routine-load) Make routine load work with old kafka version (#7630)

Browse Source 
Co-authored-by: caiconghui1 <caiconghui1@jd.com>
This commit is contained in:
caiconghui
2022-01-10 17:30:24 +08:00
committed by GitHub
parent 68c87de69e
commit 83f6eef506
6 changed files with 20 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
be/src/runtime/routine_load/data_consumer.cpp
View File

@ -77,6 +77,7 @@ Status KafkaDataConsumer::init(StreamLoadContext* ctx) {
RETURN_IF_ERROR(set_conf("auto.offset.reset", "error"));
RETURN_IF_ERROR(set_conf("api.version.request", "true"));
RETURN_IF_ERROR(set_conf("api.version.fallback.ms", "0"));
RETURN_IF_ERROR(set_conf("broker.version.fallback", config::kafka_broker_version_fallback));
for (auto& item : ctx->kafka_info->properties) {
if (starts_with(item.second, "FILE:")) {