Шаги, перечисленные ниже, предназначены для краткого ознакомления с 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