Skip to main content
emisar

Kafka cluster operations

v0.1.4

Topic introspection, consumer-group lag, broker config, ACLs, and narrow mutators (reset_offsets, alter_topic_retention, delete_consumer_group, preferred_leader_election). Auth via KAFKA_BOOTSTRAP env var on the runner host plus optional KAFKA_COMMAND_CONFIG (jaas / SASL / SSL).

15 allowed by default 3 need approval by default 2 denied by default
Pack ID
kafka
Vendor
emisar
OS
linux
Actions
20
Required binaries. Install these on the host before relying on the pack — an action that calls a missing one fails at run time.
kafka-topics.sh

Install

emisar pack install fetches this pack, re-validates it, and verifies its content hash against the --hash below — the exact bytes this page was rendered against, so a tampered copy is rejected — before copying it into the runner's packs dir. The command reloads a running daemon itself; no manual restart.

on the runner host 
sudo emisar pack install kafka --hash sha256:94cac797fc67f31d5f963ed98c44d2d59342a0cf9007a508d55682698bcccad0

Actions 20 total

View on GitHub
  • kafka.alter_topic_retention exec high

    Set topic retention.ms

    Sets `retention.ms` on a topic. Lower values cause old data to be deleted in the next log roll.

    View source on GitHub
  • kafka.broker_api_versions exec low

    Broker API versions

    Show the API protocol versions supported by each broker. Useful to confirm rolling upgrade.

    View source on GitHub
  • kafka.broker_configs exec low

    Broker configs

    List all broker-level configs (dynamic + static + defaults).

    View source on GitHub
  • kafka.cluster_info exec low

    Cluster metadata

    Show broker IDs, controller, cluster ID. Read-only.

    View source on GitHub
  • kafka.consumer_lag exec low

    Consumer lag for a group

    Show per-partition lag (log-end-offset minus committed offset) for one consumer group. The canonical "is consumption keeping up?" check.

    View source on GitHub
  • kafka.delete_consumer_group exec high

    Delete consumer group

    Removes a consumer group from the coordinator. The group must be empty (no active members).

    View source on GitHub
  • kafka.describe_group exec low

    Describe consumer group

    Show member list, partition assignment, host for one consumer group.

    View source on GitHub
  • kafka.describe_topic exec low

    Describe topic

    Show partition layout, leaders, ISR, replicas for one topic.

    View source on GitHub
  • kafka.leader_partitions exec low

    Partition leaders by broker

    Count partitions where each broker is leader. Uneven distribution → preferred-leader election.

    View source on GitHub
  • kafka.list_acls exec low

    List ACLs

    List every ACL binding on the cluster.

    View source on GitHub
  • kafka.list_consumer_offsets exec low

    Committed offsets per partition

    Show the same view as consumer_lag but emphasizes committed-offset reading. Useful before reset_offsets.

    View source on GitHub
  • kafka.list_groups exec low

    List consumer groups

    List all consumer groups in the cluster.

    View source on GitHub
  • kafka.list_topics exec low

    List topics

    List all topics in the cluster.

    View source on GitHub
  • kafka.preferred_leader_election exec high

    Trigger preferred-leader election

    Forces preferred-leader election cluster-wide. Use after a broker restart leaves leaders skewed.

    View source on GitHub
  • kafka.reassign_status exec low

    Partition reassignment status

    Show the status of any in-flight partition reassignments.

    View source on GitHub
  • kafka.reset_offsets_to_earliest exec critical

    Reset group offsets to earliest

    Rewinds a consumer group's offsets to the start of every partition. Causes a full replay — can be hours to days of duplicate processing.

    View source on GitHub
  • kafka.reset_offsets_to_latest exec critical

    Reset group offsets to latest (skip all)

    Fast-forwards a consumer group past every existing message — they will NOT be processed. Data loss for that consumer.

    View source on GitHub
  • kafka.topic_configs exec low

    Topic configs

    List topic-level overrides (retention, compaction, segment size).

    View source on GitHub
  • kafka.unavailable_partitions exec low

    Unavailable partitions

    List partitions with no leader. These mean writes are failing.

    View source on GitHub
  • kafka.under_replicated exec low

    Under-replicated partitions

    List topics + partitions with ISR < replication factor. The canonical "is replication healthy?" check.

    View source on GitHub
← Back to registry
Pack reference Publish your own →