Skip to content

Commit

Permalink
[FLINK-33401][connectors/kafka] Fix the wrong download link and versi…
Browse files Browse the repository at this point in the history
…on in the connector doc. This closes #64
  • Loading branch information
TanYuxin-tyx authored Nov 14, 2023
1 parent 5ee821b commit 18d0d77
Show file tree
Hide file tree
Showing 6 changed files with 29 additions and 11 deletions.
8 changes: 2 additions & 6 deletions docs/content.zh/docs/connectors/datastream/kafka.md
Original file line number Diff line number Diff line change
Expand Up @@ -36,16 +36,12 @@ Apache Flink 集成了通用的 Kafka 连接器,它会尽力与 Kafka client
当前 Kafka client 向后兼容 0.10.0 或更高版本的 Kafka broker。
有关 Kafka 兼容性的更多细节,请参考 [Kafka 官方文档](https://kafka.apache.org/protocol.html#protocol_compatibility)

{{< connector_artifact flink-connector-kafka 3.0.0 >}}

如果使用 Kafka source,```flink-connector-base``` 也需要包含在依赖中:

{{< artifact flink-connector-base >}}
{{< connector_artifact flink-connector-kafka kafka >}}

Flink 目前的流连接器还不是二进制发行版的一部分。
[在此处]({{< ref "docs/dev/configuration/overview" >}})可以了解到如何链接它们,从而在集群中运行。

{{< py_download_link "kafka" >}}
{{< py_connector_download_link "kafka" >}}

## Kafka Source
{{< hint info >}}
Expand Down
2 changes: 1 addition & 1 deletion docs/content.zh/docs/connectors/table/kafka.md
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ Kafka 连接器提供从 Kafka topic 中消费和写入数据的能力。
依赖
------------

{{< sql_download_table "kafka" >}}
{{< sql_connector_download_table "kafka" >}}

Kafka 连接器目前并不包含在 Flink 的二进制发行版中,请查阅[这里]({{< ref "docs/dev/configuration/overview" >}})了解如何在集群运行中引用 Kafka 连接器。

Expand Down
2 changes: 1 addition & 1 deletion docs/content.zh/docs/connectors/table/upsert-kafka.md
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ Upsert Kafka 连接器支持以 upsert 方式从 Kafka topic 中读取数据并
依赖
------------

{{< sql_download_table "upsert-kafka" >}}
{{< sql_connector_download_table "kafka" >}}

Upsert Kafka 连接器不是二进制发行版的一部分,请查阅[这里]({{< ref "docs/dev/configuration/overview" >}})了解如何在集群运行中引用 Upsert Kafka 连接器。

Expand Down
4 changes: 2 additions & 2 deletions docs/content/docs/connectors/datastream/kafka.md
Original file line number Diff line number Diff line change
Expand Up @@ -36,12 +36,12 @@ The version of the client it uses may change between Flink releases.
Modern Kafka clients are backwards compatible with broker versions 0.10.0 or later.
For details on Kafka compatibility, please refer to the official [Kafka documentation](https://kafka.apache.org/protocol.html#protocol_compatibility).

{{< connector_artifact flink-connector-kafka 3.0.0 >}}
{{< connector_artifact flink-connector-kafka kafka >}}

Flink's streaming connectors are not part of the binary distribution.
See how to link with them for cluster execution [here]({{< ref "docs/dev/configuration/overview" >}}).

{{< py_download_link "kafka" >}}
{{< py_connector_download_link "kafka" >}}

## Kafka Source
{{< hint info >}}
Expand Down
2 changes: 1 addition & 1 deletion docs/content/docs/connectors/table/upsert-kafka.md
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ key will fall into the same partition.
Dependencies
------------

{{< sql_connector_download_table "upsert-kafka" >}}
{{< sql_connector_download_table "kafka" >}}

The Upsert Kafka connector is not part of the binary distribution.
See how to link with it for cluster execution [here]({{< ref "docs/dev/configuration/overview" >}}).
Expand Down
22 changes: 22 additions & 0 deletions docs/data/kafka.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,22 @@
################################################################################
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
################################################################################

version: 3.0.1
variants:
- maven: flink-connector-kafka
sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-kafka/$full_version/flink-sql-connector-kafka-$full_version.jar

0 comments on commit 18d0d77

Please sign in to comment.