Шаги, перечисленные ниже, предназначены для краткого ознакомления с Kafka.

Шаг 1. Загрузите код и поместите его в каталог

Вы хотите скачать 1.1.0 с здесь

Шаг 2. Переименуйте распакованный каталог, который вы только что скачали, в kafka (необязательно)

Вы можете проигнорировать этот шаг, но при необходимости вам нужно будет обновить свои пути, поскольку они не будут совпадать с моими.

Шаг 3. Обновите файл server.properties

добавьте следующий код в kafka / config / server.properties

port = 9092
advertised.listener = localhost

Шаг 4. Запустите сервер ZooKeeper

kafka/bin/zookeeper-server-start.sh kafka/config/zookeeper.properties

Шаг 5. Запустите сервер Kafka в новой вкладке или на новой панели

kafka/bin/kafka-server-start.sh kafka/config/server.properties

Шаг 6. Создайте тему

kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic my-topic

Шаг 7. Укажите свою тему

kafka/bin/kafka-topics.sh --list --zookeeper localhost:2181

Вы должны увидеть, как название вашей темы выводится на терминал.

Шаг 8. Запустите продюсера на новой вкладке или панели

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

Шаг 9. Начните работу с потребителя с новой вкладки или панели

kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --from-beginning

Шаг 10. Вернитесь на вкладку производителя и отправьте первое сообщение

введите новое сообщение и нажмите Enter

$ kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-topic
>wow
>

И наконец: вернитесь на вкладку клиента и просмотрите только что отправленное сообщение!

$ kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --from-beginning
wow

Если у вас возникли проблемы с остановкой вашего сервера kafka, выполните следующую команду, пока ваш сервер zookeeper все еще работает.

kafka/bin/kafka-server-stop.sh config/server.properties