Создаем записи на тестовом продюсере, генерируя значение и ключ через разделить «:»
Shell
x
1
1
sh kafka-console-producer.sh --topic test --property "parse.key=true" --property "key.separator=:" --bootstrap-server server1:9092,server2:9092,server3:9092Тест производительности
Shell
xxxxxxxxxx1
1
1
sh kafka-producer-perf-test.sh --topic test --num-records 10000000000 --record-size 250 --throughput 1000000 --producer-props acks=1 buffer.memory=67108864 compression.type=none batch.size=8196 linger.ms=0 retries=0 bootstrap.servers=server1:9092,server2:9092,server3:9092Тестовый потребитель
Shell
xxxxxxxxxx1
1
1
sh kafka-console-consumer.sh --topic loader_humans_organizations --property print.key=true --property print.value=true --property key.separator=":" --bootstrap-server server1:9092,server2:9092,server3:9092Выборы лидера
Shell
xxxxxxxxxx1
1
1
sh kafka-console-consumer.sh --topic loader_humans_organizations --property print.key=true --property print.value=true --property key.separator=":" --bootstrap-server server1:9092,server2:9092,server3:9092Темы
Shell
xxxxxxxxxx1
2
1
sh kafka-consumer-groups.sh --list --bootstrap-server server:9092,server:9092,server:9092,server:9092 # посмотр списока тем2
sh kafka-consumer-groups.sh --bootstrap-server server:9092,server:9092,server:9092,server:9092 --describe --group GroupName # посмотр список консюмеров по теме