0
Follow
0
View

Flink: Could not find any factory for identifier 'kafka' that implements 'org.apache.flink.table.factories.CatalogFactory' in the classpath

Cy279545615 注册会员
2023-01-25 10:01

All catalogs defined using YAML must provide a type property that specifies the type of catalog. The following types are supported out of the box:

  • generic_in_memory
  • hive

You can read more about in official doc

You can create your so-called initialization SQL file like:

CREATE CATALOG MyCatalog WITH (
    'type' = 'hive',
    'default-database' = 'my_database',
    'hive-conf-dir' = '/etc/hive/conf'
  );

USE CATALOG MyCatalog;

CREATE TABLE MyTable(
  MyField1 INT,
  MyField2 STRING
) WITH (
  'connector' = 'kafka',
  'topic' = 'YOUR_TOPIC',
  'properties.bootstrap.servers' = 'localhost',
  'properties.group.id' = 'some_id',
  'scan.startup.mode' = 'earliest-offset',
  'format' = 'json'
)

About the Author

Question Info

Publish Time
2023-01-25 10:00
Update Time
2023-01-25 10:00

Related Question

C语言包含元素char short char int的结构体大小为何为12?

win10电脑无法进入系统

为Checkmarx中的Missing_HSTS_Header标记Spring项目

arduino开发stm32,低电平触发代码没有用。

Swin Transformer面部表情识别

如何打印printf函数内写的非英语文本(孟加拉语)?使用Vs Code

pip install scrapy 失败

关于#linux#的问题,请各位专家解答!

Linux操作系统mv命令疑问

Oracle中PowerCenter Informatica的I/O问题