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_r312738631
########## File path: docs/dev/connectors/kafka.zh.md ########## @@ -254,33 +229,24 @@ For convenience, Flink provides the following schemas: </div> </div> -When encountering a corrupted message that cannot be deserialized for any reason, there -are two options - either throwing an exception from the `deserialize(...)` method -which will cause the job to fail and be restarted, or returning `null` to allow -the Flink Kafka consumer to silently skip the corrupted message. Note that -due to the consumer's fault tolerance (see below sections for more details), -failing the job on the corrupted message will let the consumer attempt -to deserialize the message again. Therefore, if deserialization still fails, the -consumer will fall into a non-stop restart and fail loop on that corrupted -message. +当遇到因一些原因而无法反序列化的损坏消息时，这里有两个选项 - 从 `deserialize（...）` 方法抛出异常会导致作业失败并重新启动，或返回 `null` ，以允许 Flink Kafka 消费者悄悄地跳过损坏的消息。请注意，由于 Consumer 的容错能力（请参阅下面的部分以获取更多详细信息），在损坏的消息上失败作业将使 consumer 尝试再次反序列化消息。因此，如果反序列化仍然失败，则 consumer 将在该损坏的消息上进入不间断重启和失败的循环。 Review comment: How about to translate "corrupted message" as"脏数据"？ IMO, "损坏的消息" is not native. ---------------------------------------------------------------- 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: [email protected] With regards, Apache Git Services
