roxactl — CLI

roxactl работает с брокером по gRPC (порт 50051) — это собственный data-plane Roxa, независимый от Kafka-протокола. Бинарь есть в docker-образе (docker exec roxa roxactl …).

Глобальные флаги

--endpoint <URL>      адрес брокера (по умолчанию http://127.0.0.1:50051)
--user / --password   учётные данные data-plane (если включена [[auth.users]])
--tls-ca <PEM>        корневой сертификат (включает TLS; endpoint https://…)
--tls-cert/--tls-key  клиентский сертификат (mTLS)
--tls-domain <name>   ожидаемое имя в серверном сертификате

Команды

Топики

roxactl topic create <name> [--partitions N] [--retention-bytes N] [--retention-ms N]
roxactl topic list
roxactl topic describe <name>
roxactl topic delete <name>

Сообщения

roxactl produce <topic> [--partition P] [--key K] <values...>
roxactl consume <topic> [--partition 0] [--from 0] [--max 100]

Offsets и кластер

roxactl offset commit <group> <topic> <partition> <offset>
roxactl offset list
roxactl cluster status [--assignments]

Примеры

# прод с аутентификацией:
roxactl --endpoint http://SERVER:50051 --user app --password <pass> \
        topic create demo --partitions 3

# по TLS:
roxactl --endpoint https://SERVER:50051 --tls-ca ca.pem topic list

# retention: 1 ГиБ и 7 дней на топик
roxactl topic create events --partitions 3 \
        --retention-bytes 1073741824 --retention-ms 604800000