Confluent

基礎設施

透過 Neotask 在 OpenClaw 上管理 Kafka 主題、連接器和串流管道 — 透過對話監控您的 Confluent Cloud 基礎設施。

• 透過自然語言建立、配置和監控 Kafka 主題及消費者群組，無需觸碰 Confluent 控制台
• 部署和管理 Confluent 連接器，在 Kafka 和外部系統之間串流數據
• 監控叢集健康狀況、消費者延遲和吞吐量指標，確保串流基礎設施順暢運行

您可以做什麼

管理 Kafka 主題

請 Neotask 以特定分區數量和保留策略建立新的 Kafka 主題、列出您 Confluent 叢集中的所有主題，或檢查現有主題的配置。

監控消費者群組和延遲

請 Neotask 顯示特定主題的消費者群組延遲、列出所有活躍消費者群組，或識別落後的群組。消費者延遲是串流管道健康狀況的主要訊號。

部署和管理連接器

請 Neotask 部署 Confluent 連接器，將 PostgreSQL、S3 或其他來源的數據同步到 Kafka、檢查執行中連接器的狀態，或重啟失敗的連接器。

檢查叢集健康狀況和指標

請 Neotask 查詢當前叢集吞吐量、分區領導者分佈或代理健康狀況。OpenClaw 查詢 Confluent 的指標 API 並返回清晰的健康摘要。

管理 Schema Registry

請 Neotask 列出已登錄的 schema、檢查版本之間的 schema 相容性，或登錄新的 Avro 或 JSON schema。

試著這樣問

"建立一個名為 \'user-events\' 的新 Kafka 主題，12 個分區，保留 7 天"

"\'transactions\' 主題上 \'payments-processor\' 消費者群組的消費者延遲是多少？"

"列出我 Confluent 叢集中的所有連接器及其當前狀態"

"重啟 \'postgres-source\' 連接器 — 它處於失敗狀態"

"顯示我 Confluent 叢集過去一小時的吞吐量指標"

專業提示

延遲是關鍵指標 — 消費者延遲告訴您串流管道健康狀況的一切；在任何 schema 或程式碼變更前後都要檢查延遲。

分區數量是永久性的 — 您可以增加主題分區但無法減少；在建立主題之前請確認您的分區數量。

Schema 相容性模式 — Confluent Schema Registry 支援 BACKWARD、FORWARD、FULL 和 NONE 相容性；在登錄可能破壞消費者的 schema 變更之前，請先驗證模式。

連接器任務數量 — 每個 Confluent 連接器執行可配置數量的任務；當連接器跟不上來源數據量時，請調整任務數量。

Works Well With

• anthropic - Connect Anthropic Claude with Confluent for real-time AI event stream processing. Build intelligent data pipelines power...
• sentry - Connect Confluent Kafka with Sentry error monitoring to stream errors, track incidents, and route alerts through your ev...