You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by GitBox <gi...@apache.org> on 2022/01/06 11:27:38 UTC

[GitHub] [incubator-doris] EmmyMiao87 commented on a change in pull request #7630: [improvement](routine-load) Make routine load work with old kafka version

EmmyMiao87 commented on a change in pull request #7630:
URL: https://github.com/apache/incubator-doris/pull/7630#discussion_r779481584



##########
File path: docs/zh-CN/administrator-guide/load-data/routine-load-manual.md
##########
@@ -85,7 +85,7 @@ FE 中的 JobScheduler 根据汇报结果,继续生成后续新的 Task,或
 
 1. 支持无认证的 Kafka 访问,以及通过 SSL 方式认证的 Kafka 集群。
 2. 支持的消息格式为 csv, json 文本格式。csv 每一个 message 为一行,且行尾**不包含**换行符。
-3. 仅支持 Kafka 0.10.0.0(含) 以上版本。
+3. 仅支持 Kafka 0.10.0.0(含) 以上版本。如果要使用 Kafka 0.10.0.0 以下版本 (0.9.0, 0.8.2, 0.8.1, 0.8.0),需要修改 be 的配置,将 kafka_api_version_request 的值设置为false,将 kafka_broker_version_fallback 的值设置为要兼容的旧版本,使用旧版本的代价是routine load 的部分新特性无法使用,如根据时间设置 kafka 分区的 offset。

Review comment:
       ```suggestion
   3. 默认支持 Kafka 0.10.0.0(含) 以上版本。如果要使用 Kafka 0.10.0.0 以下版本 (0.9.0, 0.8.2, 0.8.1, 0.8.0),需要修改 be 的配置,将 kafka_api_version_request 的值设置为false,将 kafka_broker_version_fallback 的值设置为要兼容的旧版本,使用旧版本的代价是routine load 的部分新特性无法使用,如根据时间设置 kafka 分区的 offset。
   ```




-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org