You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sn...@apache.org on 2025/01/13 21:03:49 UTC
(flink-connector-hive) 19/22: [hotfix][doc] Update the Kafka DDL example in the hive catalog page to the new parameter style
This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-hive.git
commit 4aefc5b48294330d52cfdf81226b773d0a5fc1f0
Author: Feng Jin <ji...@gmail.com>
AuthorDate: Thu Feb 29 00:03:27 2024 +0800
[hotfix][doc] Update the Kafka DDL example in the hive catalog page to the new parameter style
---
docs/content.zh/docs/connectors/table/hive/hive_catalog.md | 12 ++++++------
docs/content/docs/connectors/table/hive/hive_catalog.md | 12 ++++++------
2 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/docs/content.zh/docs/connectors/table/hive/hive_catalog.md b/docs/content.zh/docs/connectors/table/hive/hive_catalog.md
index c8ca73da..847eda3b 100644
--- a/docs/content.zh/docs/connectors/table/hive/hive_catalog.md
+++ b/docs/content.zh/docs/connectors/table/hive/hive_catalog.md
@@ -183,12 +183,12 @@ Create a simple Kafka table with Flink SQL DDL, and verify its schema.
Flink SQL> USE CATALOG myhive;
Flink SQL> CREATE TABLE mykafka (name String, age Int) WITH (
- 'connector.type' = 'kafka',
- 'connector.version' = 'universal',
- 'connector.topic' = 'test',
- 'connector.properties.bootstrap.servers' = 'localhost:9092',
- 'format.type' = 'csv',
- 'update-mode' = 'append'
+ 'connector' = 'kafka',
+ 'topic' = 'test',
+ 'properties.bootstrap.servers' = 'localhost:9092',
+ 'properties.group.id' = 'testGroup',
+ 'scan.startup.mode' = 'earliest-offset',
+ 'format' = 'csv'
);
[INFO] Table has been created.
diff --git a/docs/content/docs/connectors/table/hive/hive_catalog.md b/docs/content/docs/connectors/table/hive/hive_catalog.md
index 3518b631..812bf519 100644
--- a/docs/content/docs/connectors/table/hive/hive_catalog.md
+++ b/docs/content/docs/connectors/table/hive/hive_catalog.md
@@ -183,12 +183,12 @@ Create a simple Kafka table with Flink SQL DDL, and verify its schema.
Flink SQL> USE CATALOG myhive;
Flink SQL> CREATE TABLE mykafka (name String, age Int) WITH (
- 'connector.type' = 'kafka',
- 'connector.version' = 'universal',
- 'connector.topic' = 'test',
- 'connector.properties.bootstrap.servers' = 'localhost:9092',
- 'format.type' = 'csv',
- 'update-mode' = 'append'
+ 'connector' = 'kafka',
+ 'topic' = 'test',
+ 'properties.bootstrap.servers' = 'localhost:9092',
+ 'properties.group.id' = 'testGroup',
+ 'scan.startup.mode' = 'earliest-offset',
+ 'format' = 'csv'
);
[INFO] Table has been created.