Skip to content

Latest commit

 

History

History
31 lines (26 loc) · 1.01 KB

actions.md

File metadata and controls

31 lines (26 loc) · 1.01 KB

Получить список топиков

docker exec -ti kafka /usr/bin/kafka-topics --list --bootstrap-server localhost:9092

Отправить сообщение

docker exec -ti kafka /usr/bin/kafka-console-producer --topic topic1 --bootstrap-server localhost:9092

Каждая строка - одно сообщение. Прервать - Ctrl+Z

Получить сообщения

docker exec -ti kafka /usr/bin/kafka-console-consumer --from-beginning --topic topic1 --bootstrap-server localhost:9092

Получить сообщения как consumer1

docker exec -ti kafka /usr/bin/kafka-console-consumer --group consumer1 --topic topic1 --bootstrap-server localhost:9092

Отправить сообщение с ключом через двоеточие (key:value)

docker exec -ti kafka /usr/bin/kafka-console-producer \
  --topic topic1 \
  --property "parse.key=true" \
  --property "key.separator=:" \
  --bootstrap-server \
  localhost:9092