用途:排查 OceanBase 社区版经 OMS 同步到 Kafka 时的延迟、吞吐不足或组件跟不上(如 Incr-Sync 落后 Store),并调优全量导入与增量同步。
主要能力:配置 Kafka 数据源与 KafkaSink 的读写并发、RPS/BPS 限速、序列化与分区规则;优化 OMS 平台线程、批处理、连接数与 JVM;调整 OceanBase 服务端参数与表结构以配合同步负载。
使用方式:OMS 日志用 Agent 工具 gather_oms_log(封装 obdiag gather oms_log),成功后在同一轮对 pack 目录 file_list / file_read,遇 .tar.gz / .zip 先 run_shell 解压(需审批)。config.yml 的 oms 段必须配置正确,否则采集失败;CDC 类 scope 常需 oms_component_id,格式为 IP-进程编号。无 Agent 时可手动执行 obdiag gather oms_log。
调优要点:OMS 侧可调大 limitator.platform.threads.number、limitator.select.batch.max、limitator.image.insert.batch.max、limitator.datasource.connections.max 及 JVM 堆;Kafka 侧关注全量/增量并发与限速、消息顺序、KafkaSink 序列化与分区;OB 源端可开启 enable_clog_persistence_compress,调整 merge_thread_count、_mini_merge_concurrency、minor_merge_concurrency、freeze_trigger_percentage、memstore_limit_percentage、writing_throttling_trigger_percentage。
适用场景:OMS 到 Kafka 同步链路的性能诊断与参数调优。
限制:analyze_log 仅用于 observer 侧,不能替代 OMS 日志分析;observer 日志、OBProxy 日志、单条 SQL 分析、ASH/AWR 分别由其它 skill 负责;参数名随版本变化,需以当前 OMS 版本文档为准;ALTER SYSTEM 等变更需 DBA 在维护窗口执行,Agent 默认 db_query 只读,仅输出建议 SQL 与运维步骤。