Исходный код вики Запуск
Версия 5.1 от Alexandr Fokin на 2021/08/18 19:32
Последние авторы
| author | version | line-number | content |
|---|---|---|---|
| 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 | |||
| 15 | __У данного метода есть весомый недостаток: нестабильная работа и подение системы при некоторых действиях__ | ||
| 16 | Например ошибка возникала при удалении топиков. Послее ошибки сервер Kafka не запускается и приходиться очищать папки, указанные ниже, соотвественно перезапуская Zookeper и Kafka. | ||
| 17 | Простой способ сбросить состояние тестового локального инстанса - удалить содержимое папок: | ||
| 18 | Drive:\tmp\kafka-logs | ||
| 19 | Drive:\tmp\zookeeper | ||
| 20 | |||
| 21 | Для взаимодействия с ApacheKafka можное использовать консоль. Управляющие скрипты распологаются в папке: | ||
| 22 | kafka_2.12-2.4.0\bin\windows | ||
| 23 | |||
| 24 | |||
| 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 | |||
| 29 | Виртуальная машина с развернутыми и запущенными Zookeper и Kafka. | ||
| 30 | Username: bitnami | ||
| 31 | Password: bitnami | ||
| 32 | В Kafka по умолчанию включена авторизация. | ||
| 33 | |||
| 34 | 1) Скачать образ и импортировать его в Vbox | ||
| 35 | |||
| 36 | 2) Для доступа извне открыть порты: | ||
| 37 | sudo ufw allow 9092 | ||
| 38 | |||
| 39 | 3) Взять кредлы из конфига | ||
| 40 | |||
| 41 | В виртуальной машине путь к кофигам: | ||
| 42 | /opt/bitnami/kafka/config | ||
| 43 | server.properties - общие настройки kafka | ||
| 44 | kafka_jaas.conf - данные для авторизации | ||
| 45 | |||
| 46 | {{code language="c#"}} | ||
| 47 | //Примеры конфига для Confluent.Kafka | ||
| 48 | new AdminClientConfig | ||
| 49 | { | ||
| 50 | BootstrapServers = "127.0.0.1:9092", | ||
| 51 | |||
| 52 | SaslMechanism = SaslMechanism.Plain, | ||
| 53 | SecurityProtocol = SecurityProtocol.SaslPlaintext, | ||
| 54 | SaslUsername = <UserFromConfig>, | ||
| 55 | SaslPassword = <PasswordFromConfig> | ||
| 56 | } | ||
| 57 | {{/code}} | ||
| 58 | |||
| 59 | |||
| 60 | 3) ** Docker-Compose** | ||
| 61 | Guide to Setting Up Apache Kafka Using Docker | ||
| 62 | https://www.baeldung.com/ops/kafka-docker-setup |