wuchong commented on a change in pull request #9415: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into C… URL: https://github.com/apache/flink/pull/9415#discussion_r312738024
########## File path: docs/dev/connectors/kafka.zh.md ########## @@ -150,44 +139,40 @@ To use the universal Kafka connector add a dependency to it: </dependency> {% endhighlight %} -Then instantiate the new source (`FlinkKafkaConsumer`) and sink (`FlinkKafkaProducer`). -The API is backward compatible with the Kafka 0.11 connector, -except of dropping specific Kafka version from the module and class names. +然后,实例化 source ( `FlinkKafkaConsumer` ) 和 sink ( `FlinkKafkaProducer` ) 。除了从模块和类名中删除了特定的 Kafka 版本外,这个 API 向后兼容 Kafka 0.11 版本的 connector 。 ## Kafka Consumer -Flink's Kafka consumer is called `FlinkKafkaConsumer08` (or 09 for Kafka 0.9.0.x versions, etc. -or just `FlinkKafkaConsumer` for Kafka >= 1.0.0 versions). It provides access to one or more Kafka topics. +Flink 的 Kafka consumer 称为 `FlinkKafkaConsumer08` (或者 Kafka 0.9.0.x 版本的 Kafka consumer 是 `FlinkKafkaConsumer09` ,或仅 FlinkKafkaConsumer 适用于 Kafka >= 1.0.0 的版本)。它提供对一个或多个 Kafka topics 的访问。 -The constructor accepts the following arguments: +构造函数接受以下参数: -1. The topic name / list of topic names -2. A DeserializationSchema / KafkaDeserializationSchema for deserializing the data from Kafka -3. Properties for the Kafka consumer. - The following properties are required: - - "bootstrap.servers" (comma separated list of Kafka brokers) - - "zookeeper.connect" (comma separated list of Zookeeper servers) (**only required for Kafka 0.8**) - - "group.id" the id of the consumer group +1. Topic 名称或者 Topics 的名称列表 +2. 用于反序列化 Kafka 数据的 DeserializationSchema 或者 KafkaDeserializationSchema +3. Kafka consume 的属性。需要以下属性: Review comment: ```suggestion 3. Kafka 消费者的属性。需要以下属性: ``` ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services