Flink CDC有谁能帮忙解释一下o.debezium.DebeziumException: The db history topic or its content is fully or partially missing. Please check database history topic configuration and re-execute the snapshot?with (
'schema-name' = 'AIRLINE',
'debezium.database.tablename.case.insensitive' = 'false',
'connector' = 'oracle-cdc',
'hostname' = '10.73.116.113',
'port' = '1521',
'username' = 'c##flinkuser',
'password' = 'ASAAAAAAAAA',
'database-name' = 'MUS',
'debezium.database.pdb.name' = 'B2C',
'table-name' = 'T_TRADING_ORDER',
'debezium.log.mining.strategy' = 'online_catalog',
'debezium.database.history.kafka.topic' = 'B2C_T_TRADING_ORDER'
);
io.debezium.DebeziumException: The db history topic or its content is fully or partially missing. Please check database history topic configuration and re-execute the snapshot
"database.history.kafka.bootstrap.servers" : "kafka:9092", 这个没配, 没装kafkahttps://github.com/ververica/flink-cdc-connectors/issues/1737
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
Flink CDC 是 Apache Flink 的一款开源的数据集成框架,它可以从各个数据源(如 MySQL、PostgreSQL、Oracle 等)读取数据,并将数据写入到 Flink 的内部状态存储中或者外部系统(如 Kafka、Elasticsearch 等)。
Flink CDC 使用了 Change Data Capture 技术,该技术可以捕获数据库中的数据变化,并将这些变化转换成 Flink 的数据流。Flink 可以使用这些数据流来进行实时分析、机器学习等应用。
Flink CDC 具有以下特点:
支持从各种数据源读取数据,包括关系型数据库、NoSQL 数据库、文件系统等。
支持数据增量读取,只读取数据库中发生变化的数据。
支持数据的流式处理,可以实时分析数据。
可以将数据写入到 Flink 的内部状态存储中,也可以写入到外部系统中。
Flink CDC 可以广泛应用于数据分析、机器学习等领域。
以下是一些使用场景:
实时分析业务数据,以发现业务规则的异常。
对数据进行实时预测,以进行决策支持。
将数据存储到外部系统,以供其他应用程序使用。
Flink CDC 是一个很强大的数据集成框架,它可以帮助您解决各种数据相关的问题。如果您需要实时分析数据,那么 Flink CDC 是一个很好的选择。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。