public class OnDemandAudit
extends Object
This tool is for running audit job for given topic and partitions and
getting status of most recent audit job completed for entire cluster
SAMPLE USAGE:
Note: For any audit job command, you can specify below optional arguments
--force #shutsdowns currently running jobs and starts new one
--compaction-check #skips compaction checks
1. Start audit job for entire cluster
$> /opt/confluent/bin/kafka-run-class.sh \
kafka.durability.ondemand.OnDemandAudit \
--run-audit \
--cluster
2. Start audit job for all partitions on single broker
$> /opt/confluent/bin/kafka-run-class.sh \
kafka.durability.ondemand.OnDemandAudit \
--run-audit \
--broker-id
3. Start audit job for all partitions for single topic
$> /opt/confluent/bin/kafka-run-class.sh \
kafka.durability.ondemand.OnDemandAudit \
--run-audit \
--topic-name
4. Start audit job for given topic and partition
$> /opt/confluent/bin/kafka-run-class.sh \
kafka.durability.ondemand.OnDemandAudit \
--run-audit
--topic-name \
--partition
5. Start audit job for all multiple topics and partitions
$> /opt/confluent/bin/kafka-run-class.sh \
kafka.durability.ondemand.OnDemandAudit \
--run-audit \
--topic-partition-file
6. Start audit job on broker for given topic and partition
$> /opt/confluent/bin/kafka-run-class.sh \
kafka.durability.ondemand.OnDemandAudit \
--run-audit \
--broker-id \
--topic-name \
--partition
7. Get status of most recent audit job run in the cluster
$> /opt/confluent/bin/kafka-run-class.sh \
kafka.durability.ondemand.OnDemandAudit \
--status \
--job-id
8. Get status of most recent audit job runs on given broker
$> /opt/confluent/bin/kafka-run-class.sh \
kafka.durability.ondemand.OnDemandAudit \
--status \
--job-id \
--broker-id
9. Get status detail of most recent audit job runs on given broker
$> /opt/confluent/bin/kafka-run-class.sh \
kafka.durability.ondemand.OnDemandAudit \
--status \
--job-id
--detail \
--broker-id
10. Stop any currently running audit jobs in the cluster
$> /opt/confluent/bin/kafka-run-class.sh \
kafka.durability.ondemand.OnDemandAudit \
--stop