Flink CDC Issue Import created FLINK-34814:
----------------------------------------------
Summary: [Bug] java.lang.NoClassDefFoundError: Could not
initialize class org.apache.kafka.connect.json.JsonConverterConfig
Key: FLINK-34814
URL: https://issues.apache.org/jira/browse/FLINK-34814
Project: Flink
Issue Type: Bug
Components: Flink CDC
Reporter: Flink CDC Issue Import
### Search before asking
- [X] I searched in the
[issues|https://github.com/ververica/flink-cdc-connectors/issues) and found
nothing similar.
### Flink version
1.14.0
### Flink CDC version
2.3.0
### Database and its version
MySQL5.7
### Minimal reproduce step
//设置相关ck的参数
env.enableCheckpointing(360000L);
env.getCheckpointConfig().setMaxConcurrentCheckpoints(1);
env.getCheckpointConfig().setCheckpointTimeout(360000L);
env.getCheckpointConfig().setFailOnCheckpointingErrors(false);
env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE);
env.getCheckpointConfig().enableExternalizedCheckpoints(CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);
//cdc的相关参数
Properties prop = new Properties();
prop.setProperty("snapshot.locking.mode","none");
//使用cdc来读取binlog日志
DebeziumSourceFunction<String> dataSource =
MySqlSource.<String>builder()
.hostname("")
.port(3306)
.username("rp")
.password("u5")
.databaseList("iap")
.tableList("iap.cdc_test_1")
.deserializer(new JsonDebeziumDeserializationSchema())
.startupOptions(StartupOptions.latest())
.debeziumProperties(prop)
.build();
SingleOutputStreamOperator<String> streamSource =
env.addSource(dataSource).name("data-source");
streamSource.print("======>"+streamSource];
but it causes an error:
java.lang.NoClassDefFoundError: Could not initialize class
org.apache.kafka.connect.json.JsonConverterConfig
### What did you expect to see?
run success
### What did you see instead?
success
### Anything else?
no
### Are you willing to submit a PR?
- [X] I'm willing to submit a PR!
---------------- Imported from GitHub ----------------
Url: https://github.com/apache/flink-cdc/issues/2491
Created by: [ccc66666|https://github.com/ccc66666]
Labels: bug,
Created at: Thu Sep 14 11:14:15 CST 2023
State: open
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
