Commands

Every group answers --help.

Kafka

fh kafka cluster list
fh kafka broker get 1
fh kafka topic get orders
fh kafka topic create orders --partitions 6 --replication-factor 3
fh kafka topic config update orders retention.ms 604800000
fh kafka group get analytics
fh kafka group reset-offsets analytics --assignment orders:0:100
fh kafka connect connector list --connect c1
fh kafka connect connector restart orders-sink --connect c1
fh kafka schema subject get orders-value --registry r1
fh kafka quota client create alice app1 --producer-byte-rate 1048576
fh kafka producer transaction fence p1

Cluster-scoped commands take --cluster or the configured default. Connect clusters and schema registries are scope too: --connect, --registry (--registry may be omitted when the deployment has one registry).

Config, auth, TUI, skills

fh config configure
fh config context list | use <name> | show [name] | rename <old> <new> | delete <name>
fh config switch context | tenant | cluster
fh config set base-url | username | password | tenant | cluster | oidc-client-id | oidc-callback-port | theme
fh auth login [--status] [--callback-port N]
fh tui [--cluster ID]
fh skills list | install [--agent agents|claude|project] [--dir PATH] [--force]
fh version

Writes

State-changing commands print what they did, or Mutation staged for admin approval where changes are reviewed first.

Large values (a schema, a connector config) accept inline text, @file, or - for stdin:

fh kafka schema subject create orders-value --registry r1 \
  --schema-type AVRO --schema @orders.avsc

Every command

Generated from fh --help. Scope flags (--cluster, --connect, --registry, --context) and the global output flags are omitted; <…> is an argument, [<…>] an optional one.

fh kafka cluster list
fh kafka cluster kraft-quorum
fh kafka cluster reassignment list
fh kafka cluster reassignment alter --target-replica=TARGET-REPLICA,... <topic> <partition>
fh kafka cluster reassignment cancel <topic> <partition>
fh kafka broker list
fh kafka broker get <broker-id>
fh kafka broker config get <broker-id>
fh kafka broker config update <broker-id> <config-name> <value>
fh kafka broker assignments <broker-id>
fh kafka broker topics <broker-id>
fh kafka broker unregister <broker-id>
fh kafka topic list
fh kafka topic get <topic>
fh kafka topic create --partitions=INT --replication-factor=INT <topic>
fh kafka topic delete <topic>
fh kafka topic config get <topic>
fh kafka topic config update <topic> <config-name> <value>
fh kafka topic partition list <topic>
fh kafka topic partition update --partition-count=INT <topic>
fh kafka topic partition delete <topic> <partition>
fh kafka topic assignments <topic>
fh kafka topic elect-leader <topic> <partition>
fh kafka group list
fh kafka group get <group-id>
fh kafka group assignments <group-id>
fh kafka group delete <group-id>
fh kafka group reset-offsets --assignment=ASSIGNMENT,... <group-id>
fh kafka connect cluster list
fh kafka connect plugin list --connect=STRING
fh kafka connect plugin validate --connect=STRING --set=KEY=VALUE;... <plugin>
fh kafka connect connector list --connect=STRING
fh kafka connect connector get --connect=STRING <connector>
fh kafka connect connector create --connect=STRING --set=KEY=VALUE;... <connector>
fh kafka connect connector delete --connect=STRING <connector>
fh kafka connect connector config get --connect=STRING <connector>
fh kafka connect connector config update --connect=STRING --set=KEY=VALUE;... <connector>
fh kafka connect connector stop --connect=STRING <connector>
fh kafka connect connector restart --connect=STRING <connector>
fh kafka connect connector pause --connect=STRING <connector>
fh kafka connect connector resume --connect=STRING <connector>
fh kafka connect task list --connect=STRING <connector>
fh kafka connect task status --connect=STRING <connector> <task-id>
fh kafka connect task restart --connect=STRING <connector> <task-id>
fh kafka quota client list
fh kafka quota client create <user> <client-id>
fh kafka quota client update <user> <client-id>
fh kafka quota client delete <user> <client-id>
fh kafka quota ip list
fh kafka quota ip create --connection-creation-rate=INT <ip-address>
fh kafka quota ip update --connection-creation-rate=INT <ip-address>
fh kafka quota ip delete <ip-address>
fh kafka schema registry list
fh kafka schema subject list
fh kafka schema subject get <subject>
fh kafka schema subject create --schema-type=STRING --schema=STRING <subject>
fh kafka schema subject delete <subject>
fh kafka schema version list <subject>
fh kafka schema version get <subject> <version>
fh kafka schema version create --schema=STRING <subject>
fh kafka schema version delete <subject> <version>
fh kafka schema compatibility update <subject> <compatibility>
fh kafka schema validate --schema=STRING <subject>
fh kafka producer get <producer-id>
fh kafka producer transaction get <producer-id>
fh kafka producer transaction fence <producer-id>
fh kafka producer transaction abort <producer-id> <topic> <partition>
fh config configure
fh config context list
fh config context use <name>
fh config context show [<name>]
fh config context rename <old> <new>
fh config context delete <name>
fh config set base-url <value>
fh config set username <value>
fh config set password <value>
fh config set cluster [<value>]
fh config set tenant [<value>]
fh config set theme [<value>]
fh config set oidc-client-id <value>
fh config set oidc-callback-port <value>
fh config switch context
fh config switch tenant
fh config switch cluster
fh auth login
fh tui
fh skills list
fh skills install
fh version