Kafka ActionsΒΆ
- Get Kafka Producer Handle : Get Kafka Producer Handle
- Get Kafka broker health : Checks the health of the Kafka brokers by determining if the Kafka producer can establish a connection with the bootstrap brokers of a Kafka cluster.
- Get Kafka topic partition health : Checks the health of the Kafka topics and their partitions.This check checks if the topics have any partitions at all.
- Kafka Check In-Sync Replicas : Checks number of actual min-isr for each topic-partition with configuration for that topic.
- Kafka Check Offline Partitions : Checks the number of offline partitions.
- Kafka Check Replicas Available : Checks if the number of replicas not available for communication is equal to zero.
- Kafka Publish Message : Publish Kafka Message
- Kafka check lag change : This action checks if the lag for consumer groups is not changing for a threshold number of hours.
- Kafka get count of committed messages : Fetches the count of committed messages (consumer offsets) for a specific consumer group and its topics.
- Kafka get topic health : This action fetches the health and total number of messages for the specified topics.
- Kafka get topics with lag : This action fetches the topics with lag in the Kafka cluster.
- Run a Kafka command using kafka CLI : Run a Kafka command using kafka CLI. Eg kafka-topics.sh --list --exclude-internal