Работа с kafka

Описание топика

./bin/kafka-topics.sh --zookeeper 10.43.12.188:2181 --describe --topic MirrorTEST

Создать топик

./bin/kafka-topics.sh --create --zookeeper zk:21810 --replication-factor 3 --partitions 3 -topic MirrorTEST

Посчитать сообщения в топике

./bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.101.11:9092,192.168.101.12:9092,192.168.101.13:9092 --topic MirrorTEST --time -1 --offsets 1 | awk -F ":" '{sum += $3} END {print sum}'

Подключиться продюсером, чтобы писать сообщения

./bin/kafka-console-producer.sh \
    --broker-list localhost:9092 \
    --topic TEST

Разрешить всё для всех в ACL

bin/kafka-acls.sh --add --allow-principal User:* --consumer --authorizer-properties zookeeper.connect=zookeeper:2181 --group *

Работа с ключами, как создать jks https://medium.com/@anoopl/how-to-setup-strimzi-kafka-operator-with-mutual-tls-and-simple-authorization-b397a9ef7295

keytool -importkeystore -srckeystore user.p12 -srcstoretype pkcs12 -destkeystore user-keystore.jks -deststoretype jks

keytool -importkeystore -srckeystore kafka.server.keystore.jks -destkeystore myapp.p12 -srcalias caroot -srcstoretype jks -deststoretype pkcs12