Kafka cluster operations

Install

emisar pack install validates the pack and verifies its content hash before copying it into /etc/emisar/packs. The --hash below pins the install to the exact bytes on this page — a tampered copy is rejected. After install, reload the runner; it re-reads the catalog and advertises every action.

content hash: sha256:776ab82468147c1d45c71543af1efdb70db4cbcf14cd7bb09d1ce7fad670ae54

sudo emisar pack install kafka \
  --hash sha256:776ab82468147c1d45c71543af1efdb70db4cbcf14cd7bb09d1ce7fad670ae54 \
  --dest /etc/emisar/packs

# Reload so the runner re-reads the catalog:
sudo systemctl reload emisar

• kafka.alter_topic_retention exec high

  Set topic retention.ms

• kafka.broker_api_versions exec low

  Broker API versions

• kafka.broker_configs exec low

  Broker configs

• kafka.cluster_info exec low

  Cluster metadata

• kafka.consumer_lag exec low

  Consumer lag for a group

• kafka.delete_consumer_group exec high

  Delete consumer group

• kafka.describe_group exec low

  Describe consumer group

• kafka.describe_topic exec low

  Describe topic

• kafka.leader_partitions exec low

  Partition leaders by broker

• kafka.list_acls exec low

  List ACLs

• kafka.list_consumer_offsets exec low

  Committed offsets per partition

• kafka.list_groups exec low

  List consumer groups

• kafka.list_topics exec low

  List topics

• kafka.preferred_leader_election exec high

  Trigger preferred-leader election

• kafka.reassign_status exec low

  Partition reassignment status

• kafka.reset_offsets_to_earliest exec critical

  Reset group offsets to earliest

• kafka.reset_offsets_to_latest exec critical

  Reset group offsets to latest (skip all)

• kafka.topic_configs exec low

  Topic configs

• kafka.unavailable_partitions exec low

  Unavailable partitions

• kafka.under_replicated exec low

  Under-replicated partitions