Kafka binding spec 配置 Warning 元数据字段规范 绑定支持 Specifying a partition key 相关链接 Kafka binding spec Detailed documentation on the Kafka binding component 配置 To setup Kafka bin...

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

Kafka Configuring Kafka Logging Kafka You can configure Rancher to send cluster or project logs to a Kafka server. Configuring Kafka Logging Prerequisite: You must have ...

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

Kafka Creating a Table Description Configuration Virtual Columns Kafka This engine works with Apache Kafka . Kafka lets you: Publish or subscribe to data flows. Organize...

Apache Kafka 连接器 安装 Apache Kafka Kafka 1.0.0+ 连接器 兼容性 将 Kafka Connector 从 0.11 迁移到通用版本 用法 Kafka Consumer DeserializationSchema 配置 Kafka Consumer 开始消费的位置 Kafka Consumer 和容错 ...

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

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 Binding support Authentication Specifying a partition key Response Related links Kafka binding spec Detailed docu...

Kafka 概览 支持的版本 依赖 Maven 依赖 如何创建 Kafka Load 节点 SQL API 用法 InLong Dashboard 用法 InLong Manager Client 用法 Kafka Load 节点参数 可用的元数据字段 特征 支持动态 Schema 写入 动态 Topic 提取 动态 Partition...