Strimzi Kafka CLI

Strimzi Kafka CLI — это интерфейс командной строки (CLI), который помогает традиционным пользователям Apache Kafka — как разработчикам, так и администраторам — легко адаптироваться к Strimzi — оператору Kubernetes для Apache Kafka.

Основная цель — ускорить освоение Strimzi за счёт создания похожего опыта работы с CLI, аналогичного традиционным инструментам Apache Kafka, которые в обычном пакете Kafka в основном начинаются с префикса kafka-* и располагаются в каталоге bin.

Strimzi Kafka CLI использует команду kfk как сокращение от «Kafka For Kubernetes» («Kafka для Kubernetes») или просто «k a f k a», что напоминает префикс kafka-* в именах обычных скриптовых файлов Kafka.

Хотя для некоторых общих объектов набор команд и опций схож, Strimzi Kafka CLI обладает дополнительными возможностями для управления и настройки ресурсов, связанных со Strimzi.

Ниже приведены команды текущей версии Strimzi Kafka CLI, которые используются для разных целей:

Usage: kfk [OPTIONS] COMMAND [ARGS]...

  Strimzi Kafka CLI.

Options:
  --version  Show the version and exit.
  --help     Show this message and exit.

Commands:
  acls              Manages ACLs on Kafka.
  backup            Backs up and restores Strimzi resources.
    kafka             Backs up or restores a Kafka cluster and its resources.
    connect           Backs up or restores a Kafka Connect cluster and its connectors.
  clusters          Creates, alters, deletes, describes Kafka cluster(s).
  configs           Adds/Removes entity config for a topic, client, user...
  connect           Manages Kafka Connect clusters, connectors, and MirrorMaker2.
    clusters          Creates, alters, deletes, describes KafkaConnect cluster(s).
    connectors        Creates, alters, deletes, describes KafkaConnector(s).
    mirror-maker      Lists, describes, creates, deletes KafkaMirrorMaker2(s).
  console-consumer  Reads data from Kafka topics and outputs it to...
  console-producer  Reads data from standard input and publish it to Kafka.
  mcp               Starts the Strimzi MCP server.
  node-pools        Lists, describes, creates, deletes KafkaNodePool(s).
  operator          Installs/Uninstalls Strimzi Kafka Operator.
  topics            Creates, alters, deletes, describes Kafka topic(s).
  users             Creates, alters, deletes, describes Kafka users(s).

Подробнее см. в соответствующей статье Strimzi Kafka CLI: управление Strimzi нативным для Kafka способом.

Установка

С помощью установщика пакетов Python

pip install strimzi-kafka-cli --user

Или, чтобы установить Strimzi Kafka CLI в изолированном окружении, можно просто использовать pipx:

pipx install strimzi-kafka-cli

Для установки с поддержкой MCP-сервера:

pip install strimzi-kafka-cli[mcp] --user

Или с помощью pipx:

pipx install strimzi-kafka-cli[mcp]

С помощью Homebrew

#Tap the homebrew repository first.
brew tap systemcraftsman/strimzi-kafka-cli

#Install Strimzi Kafka CLI
brew install strimzi-kafka-cli

Установка CLI через Homebrew уже использует виртуальное окружение, поэтому не нужно беспокоиться об основном окружении Python. Поддержка MCP-сервера включена по умолчанию.

Для проекта требуется: Python >=3.11

Примеры

• TLS-аутентификация
• Простая авторизация ACL
• Конфигурация топиков, пользователей и брокеров
• Kafka Connect

MCP-сервер

Strimzi Kafka CLI включает MCP-сервер (Model Context Protocol), который позволяет ИИ-ассистентам управлять развёртываниями Strimzi Kafka на Kubernetes.

Запуск MCP-сервера

kfk mcp

Регистрация в Claude Code

claude mcp add strimzi-kafka-cli -- kfk mcp

Доступные инструменты (42)

Зависимости

Зависимости Python

См. файл pyproject.toml.

Внешние зависимости

Ресурсы Strimzi resources автоматически загружаются при первом запуске команды kfk. Strimzi Kafka CLI использует клиент Kubernetes для Python для прямого взаимодействия с кластером. Проверить версии зависимостей можно с помощью:

kfk --version