Исходный код вики Запуск
Версия 3.1 от Alexandr Fokin на 2020/08/15 22:09
Скрыть последних авторов
author | version | line-number | content |
---|---|---|---|
![]() |
2.1 | 1 | |
2 | **1) Запуск на windows** | ||
3 | Простой запуст на Windows: | ||
4 | 1) Раскоменнтировать и изменить строки в файле: | ||
5 | kafka_2.12-2.4.0\config\server.properties | ||
6 | listeners=PLAINTEXT://127.0.0.1:9092 | ||
7 | advertised.listeners=PLAINTEXT://127.0.0.1:9092 | ||
8 | |||
9 | 2) Запустить ZooKeeper | ||
10 | kafka_2.12-2.4.0\bin\windows\zookeeper-server-start.bat "kafka_2.12-2.4.0\config\zookeeper.properties" | ||
11 | |||
12 | 3) Запустить Kafka | ||
13 | kafka_2.12-2.4.0\bin\windows\kafka-server-start.bat "kafka_2.12-2.4.0\config\server.properties" | ||
14 | |||
![]() |
3.1 | 15 | __У данного метода есть весомый недостаток: нестабильная работа и подение системы при некоторых действиях__ |
16 | Например ошибка возникала при удалении топиков. Послее ошибки сервер Kafka не запускается и приходиться очищать папки, указанные ниже, соотвественно перезапуская Zookeper и Kafka. | ||
17 | Простой способ сбросить состояние тестового локального инстанса - удалить содержимое папок: | ||
18 | Drive:\tmp\kafka-logs | ||
19 | Drive:\tmp\zookeeper | ||
![]() |
2.1 | 20 | |
![]() |
3.1 | 21 | Для взаимодействия с ApacheKafka можное использовать консоль. Управляющие скрипты распологаются в папке: |
22 | kafka_2.12-2.4.0\bin\windows | ||
23 | |||
24 | |||
![]() |
2.1 | 25 | 2) ** VBox. Bitnami Kafka machine** |
26 | https://bitnami.com/stack/kafka/virtual-machine | ||
27 | https://docs.bitnami.com/virtual-machine/infrastructure/kafka/administration/ | ||
28 | |||
![]() |
3.1 | 29 | Виртуальная машина с развернутыми и запущенными Zookeper и Kafka. |
30 | Username: bitnami | ||
31 | Password: bitnami | ||
32 | В Kafka по умолчанию включена авторизация. | ||
33 | |||
![]() |
2.1 | 34 | 1) Скачать образ и импортировать его в Vbox |
35 | |||
36 | 2) Для доступа извне открыть порты: | ||
![]() |
3.1 | 37 | sudo ufw allow 9092 |
![]() |
2.1 | 38 | |
39 | 3) Взять кредлы из конфига | ||
40 | |||
41 | В виртуальной машине путь к кофигам: | ||
42 | /opt/bitnami/kafka/config | ||
43 | server.properties - общие настройки kafka | ||
44 | kafka_jaas.conf - данные для авторизации |