Flink CDC有谁能帮忙解释一下?

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

展开
收起
真的很搞笑 2023-09-13 15:01:06 175 分享 版权
1 条回答
写回答
取消 提交回答
  • 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 是一个很好的选择。

    2023-10-20 15:26:04
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理