使用Flink消费Kafka数据并写入MySQL的实现代码示例

由 ChatGPT4o 使用 ChatGPT 4o 回答

问题：

使用Flink进行数据处理，首先消费kafka中的销售topic，然后写入到mysql中的销售订单表（tbl_sales_order）和销售商品表（tbl_sales_goods），两张表主键id由数据库自增，它们是一对多的关系，销售商品表有外键id能关联上销售订单表的主键id。还有，销售数据中的企业id需要关联mysql中的企业表获取企业名称一同存入到销售订单表中。请给我一份详细的可实现代码。

回答：

要使用 Apache Flink 进行数据处理，首先需要设置 Flink 环境，消费 Kafka 中的销售 topic，然后将数据写入 MySQL 的销售订单表（tbl_sales_order）和销售商品表（tbl_sales_goods）。以下是一个详细的实现代码示例：

1. 设置依赖

首先，确保你的项目中包含以下依赖：

<dependencies>
    <!-- Flink dependencies -->
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-java</artifactId>
        <version>1.14.0</version>
    </dependency>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-streaming-java_2.12</artifactId>
        <version>1.14.0</version>
    </dependency>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-connector-kafka_2.12</artifactId>
        <version>1.14.0</version>
    </dependency>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-connector-jdbc_2.12</artifactId>
        <version>1.14.0</version>
    </dependency>
    <!-- MySQL connector -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.26</version>
    </dependency>
</dependencies>

2. Flink 程序代码

import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.api.common.serialization.SimpleStringSchema;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer;
import org.apache.flink.streaming.connectors.kafka.config.StartupMode;
import org.apache.flink.streaming.connectors.kafka.internals.KafkaDeserializationSchemaWrapper;
import org.apache.flink.streaming.connectors.kafka.partitioner.FlinkFixedPartitioner;
import org.apache.flink.streaming.connectors.kafka.partitioner.KafkaPartitioner;
import org.apache.flink.streaming.connectors.kafka.serialization.KafkaSerializationSchema;
import org.apache.flink.streaming.connectors.kafka.serialization.KafkaSerializationSchemaWrapper;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicSource;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableFactory;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSink;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSource;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactory;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContext;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilderBuilder;
import org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableSourceFactoryBase.KafkaDynamicTableSourceFactoryContextImpl.KafkaDynamicTableSourceFactoryContextImplBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilderBuilderBuilderBuilder.KafkaDynamicTableSourceFactoryContextImplBuilderBuilder