Исходный код вики Запуск

Версия 7.1 от Alexandr Fokin на 2022/02/26 16:18

version	line-number	content
2.1	1	1) Запуск на windows
	2	Простой запуст на Windows:
	3	1) Раскоменнтировать и изменить строки в файле:
	4	kafka_2.12-2.4.0\config\server.properties
	5	listeners=PLAINTEXT://127.0.0.1:9092
	6	advertised.listeners=PLAINTEXT://127.0.0.1:9092
	7
7.1	8	2) Запустить [[Apache ZooKeeper>>doc:Разработка.Базы данных.NoSQL.Apache ZooKeeper.WebHome]]
2.1	9	kafka_2.12-2.4.0\bin\windows\zookeeper-server-start.bat "kafka_2.12-2.4.0\config\zookeeper.properties"
	10
	11	3) Запустить Kafka
	12	kafka_2.12-2.4.0\bin\windows\kafka-server-start.bat "kafka_2.12-2.4.0\config\server.properties"
	13
3.1	14	__У данного метода есть весомый недостаток: нестабильная работа и подение системы при некоторых действиях__
	15	Например ошибка возникала при удалении топиков. Послее ошибки сервер Kafka не запускается и приходиться очищать папки, указанные ниже, соотвественно перезапуская Zookeper и Kafka.
	16	Простой способ сбросить состояние тестового локального инстанса - удалить содержимое папок:
	17	Drive:\tmp\kafka-logs
	18	Drive:\tmp\zookeeper
2.1	19
3.1	20	Для взаимодействия с ApacheKafka можное использовать консоль. Управляющие скрипты распологаются в папке:
	21	kafka_2.12-2.4.0\bin\windows
	22
	23
2.1	24	2) VBox. Bitnami Kafka machine
	25	https://bitnami.com/stack/kafka/virtual-machine
	26	https://docs.bitnami.com/virtual-machine/infrastructure/kafka/administration/
	27
7.1	28	Виртуальная машина с развернутыми и запущенными [[Apache ZooKeeper>>doc:Разработка.Базы данных.NoSQL.Apache ZooKeeper.WebHome]] и Kafka.
3.1	29	Username: bitnami
	30	Password: bitnami
	31	В Kafka по умолчанию включена авторизация.
	32
2.1	33	1) Скачать образ и импортировать его в Vbox
	34
	35	2) Для доступа извне открыть порты:
3.1	36	sudo ufw allow 9092
2.1	37
	38	3) Взять кредлы из конфига
	39
	40	В виртуальной машине путь к кофигам:
	41	/opt/bitnami/kafka/config
	42	server.properties - общие настройки kafka
	43	kafka_jaas.conf - данные для авторизации
4.1	44
	45	{{code language="c#"}}
	46	//Примеры конфига для Confluent.Kafka
	47	new AdminClientConfig
	48	{
	49	BootstrapServers = "127.0.0.1:9092",
	50
	51	SaslMechanism = SaslMechanism.Plain,
	52	SecurityProtocol = SecurityProtocol.SaslPlaintext,
	53	SaslUsername = <UserFromConfig>,
	54	SaslPassword = <PasswordFromConfig>
	55	}
	56	{{/code}}
	57
5.1	58
	59	3) Docker-Compose
	60	Guide to Setting Up Apache Kafka Using Docker
	61	https://www.baeldung.com/ops/kafka-docker-setup
	62
6.1	63	4) Другое
	64	https://github.com/lensesio/fast-data-dev

Исходный код вики Запуск

Приложения

Навигация