Описание топика
./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
0 Comment