oms-kafka-performance

Diagnose and tune OceanBase OMS-to-Kafka replication latency and throughput bottlenecks.

161|40|Updated Nov 22, 2022
One-click install
npx skills add https://github.com/oceanbase/obdiag --skill oms-kafka-performance
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: oms-kafka-performance
Source: https://github.com/oceanbase/obdiag/tree/main/plugins/agent/skills/oms-kafka-performance
Command: npx skills add https://github.com/oceanbase/obdiag --skill oms-kafka-performance

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

OceanBase Community Edition 经由 OMS 同步至 Kafka 的延迟、吞吐与限速等环节存在瓶颈与配置不当的风险。本 SOP 明确了端到端的诊断与调优流程,覆盖全量导入与增量同步、KafkaSink 的并发与序列化策略、OMS 平台 limitator 与 JVM 调优,以及源端 OB 与表结构策略,以及 observer 日志、OBProxy、单条 SQL 深查等跨角色协作要点。

Core Features & Use Cases

  • 指导诊断 OMS 到 Kafka 全链路的延迟、吞吐、以及限速瓶颈。
  • 提供面向全量导入与增量同步的调优要点、参数范围及风险提示。
  • 指导跨组件协作:observer 日志、OBProxy 与 单条 SQL 深查等相关技能的分工。

Quick Start

Collect OMS-to-Kafka performance data (latency, throughput, and limits) and apply recommended tuning steps for full- and incremental-sync scenarios.

Frequently Asked Questions about oms-kafka-performance

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I diagnose high latency in OceanBase OMS to Kafka incremental sync?

Diagnose OMS-to-Kafka incremental sync latency by collecting throughput metrics, component logs, and OMS platform configurations to identify bottlenecks across OB, OBProxy, and OMS limitators. The workflow validates parameter ranges and provides tuning recommendations with risk guardrails.

What is the best way to optimize KafkaSink settings for OceanBase data replication throughput?

Optimize KafkaSink throughput by tuning concurrency and serialization strategies to mitigate bottlenecks in OceanBase data replication. Apply the diagnostic workflow to validate parameter ranges and adjust configurations alongside OMS platform limitators and JVM settings.

Why does my OMS full-import to Kafka experience rate limiting and low performance?

OMS full-import to Kafka experiences rate limiting and low performance due to misconfigured platform limitators or JVM parameters. The tuning workflow addresses full-import scenarios by validating parameter ranges across OBS and OBProxy components to remove throughput bottlenecks.

Can I tune JVM configurations and OMS platform limits to improve Kafka data sync?

Yes, you can tune JVM configurations and OMS platform limitators to improve Kafka data sync performance. The workflow guides adjustments across OBS and OBProxy components, validating parameter ranges to provide actionable tuning recommendations with guardrails.

When should I use observer logs and OBProxy deep checks for Kafka replication diagnostics?

Use observer logs and OBProxy deep checks for Kafka replication diagnostics when cross-component collaboration is needed to isolate single SQL issues or source-side OB bottlenecks. The workflow coordinates these checks alongside OMS configurations to pinpoint latency and throughput root causes.

What are the limitations when tuning OceanBase OMS to Kafka replication parameters?

Limitations when tuning OceanBase OMS to Kafka replication parameters include risks from invalid configuration ranges and improper adjustments. The workflow provides risk guardrails by validating parameter ranges across KafkaSink, OMS platform limitators, and JVM settings before applying tuning recommendations.