kafka_tools.md

list consumer groups:

/bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list

describe consumer group -> offset, lag

/bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group GR_NAME --describe

move offset to the end:

/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic TOPIC --consumer-property group.id=GR_NAME --from-beginning --delete-consumer-offsets

delete topic:

/bin/kafka-topics.sh --zookeeper localhost:2181 --topic scheme_manager_responses_1.0 --delete

------------ WITH AUTH:

export KAFKA_OPTS="-Djava.security.auth.login.config=/opt/kafka/config/kafka_client_jaas.conf"

bin/kafka-consumer-groups.sh --bootstrap-server $HOSTNAME:9092 --describe --group scheme-manager --new-consumer --command-config config/sasl-consumer.properties

KafkaClient {
  org.apache.kafka.common.security.plain.PlainLoginModule required
  username="prdRWD"
  password="meh";
};