oms-kafka-performance

name	oms-kafka-performance
description	标准 SOP：OceanBase 社区版经 OMS 同步至 Kafka 的延迟、吞吐与调优。涵盖全量/增量并发与限速、KafkaSink、OMS 平台 limitator 与 JVM、源端 OB 与表结构策略；与 observer 日志、OBProxy、单条 SQL 深查 skill 分工明确。

OceanBase 社区版 → Kafka（OMS）：性能排查与调优

使用场景

• 排查 OMS 同步到 Kafka 的 延迟、吞吐不足 或组件跟不上（如 Incr-Sync 落后 Store）。
• 调优 全量导入（Full-Import） 或 增量同步（Incr-Sync） 到 Kafka。
• 配置 Kafka 数据源、KafkaSink 的读写并发、RPS/BPS 限速、序列化与分区规则。
• 优化 OMS 平台线程、批处理、连接数与 JVM，或 OceanBase 服务端与表结构以配合同步负载。

与其它 skill 的分工

需求	不要用本 skill 代替	应使用
Observer / election / rootservice 日志	本 skill	observer-log-analysis（gather_log / analyze_log）
OBProxy 日志	本 skill	obproxy-log-analysis
单条 SQL 计划、trace、锁	本 skill	observer-sql-analysis
时段整体 ASH/AWR、主机 perf	本 skill	obdiag-performance
官方文档参数、KafkaSink 版本差异	仅口述	oceanbase-knowledge（query 中带 OMS/OB 版本）

工具与取证（Agent）

• OMS 日志 ≠ analyze_log：analyze_log 仅 observer 侧。OMS / Ghana / CDC 用 Agent 工具 （封装 ），成功后在同一轮内对 pack 目录 / ；遇 先 解压（需审批）— 流程对齐 。