Apache Kafka 连接器 依赖 Kafka Consumer DeserializationSchema 配置 Kafka Consumer 开始消费的位置 Kafka Consumer 和容错 Kafka Consumer Topic 和分区发现 分区发现 Topic 发现 Kafka Consumer 提交 Offset 的行为配...

Apache Kafka SQL Connector Dependencies How to create a Kafka table Available Metadata Connector Options Features Key and Value Formats Topic and Partition Discovery Start Re...

Apache Kafka Connector Dependency Kafka Consumer The DeserializationSchema Kafka Consumers Start Position Configuration Kafka Consumers and Fault Tolerance Kafka Consumers Top...

Apache Kafka Connector Installing Apache Kafka Kafka 1.0.0+ Connector Compatibility Migrating Kafka Connector from 0.11 to universal Usage Kafka Consumer The DeserializationSc...

Kafka 概述 支持的版本 依赖 Maven 依赖 如何创建 Kafka Extract 节点 SQL API 用法 InLong Dashboard 用法 InLong Manager Client 用法 Kafka Extract 节点参数 可用的元数据字段 数据类型映射 Kafka 概述 Kafka Extract 节...

Apache Kafka 连接器 依赖 Kafka Source 使用方法 Topic / Partition 订阅 消息解析 起始消费位点 有界 / 无界模式 其他属性 动态分区检查 事件时间和水印 空闲 消费位点提交 监控 指标范围 Kafka Consumer 指标 安全 实现细节 数据源分片（Source Split） ...

Apache Kafka SQL 连接器 依赖 如何创建 Kafka 表 可用的元数据 连接器参数 特性 消息键（Key）与消息体（Value）的格式 Topic 和 Partition 的探测 起始消费位点 Bounded Ending Position CDC 变更日志（Changelog） Source Sink 分区 一致性保证 ...

Kafka 概述 支持的版本 依赖 Maven 依赖 如何创建 Kafka Extract 节点 SQL API 用法 InLong Dashboard 用法 InLong Manager Client 用法 Kafka Extract 节点参数 可用的元数据字段 数据类型映射 Kafka 概述 Kafka Extract 节...

Kafka Overview Supported Version Dependencies Maven dependency How to create a Kafka Load Node Usage for SQL API Usage for InLong Dashboard Usage for InLong Manager Client ...

Kafka binding spec Component format Spec metadata fields Note Binding support Authentication Specifying a partition key Response Related links Kafka binding spec Detaile...