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

Редактировал(а) Alexandr Fokin 2023/12/16 14:11

version	line-number	content
8.6	1	\|1) Запуск на [[Windows>>doc:Хостинг.Операционные системы.Windows.WebHome]]\|(((
2.1	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
10.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
8.7	20	Для взаимодействия с ApacheKafka можно использовать [[Kafka console tool>>doc:Разработка.Брокеры сообщений.Apache Kafka.Kafka console tool.WebHome]].
8.6	21	)))
	22	\|2) [[ VirtualBox>>doc:Хостинг.Виртуализация.VirtualBox.WebHome]].
	23	Bitnami Kafka machine\|(((
	24	[[(% id="cke_bm_1143S" style="display:none" %) (%%)https:~~/~~/bitnami.com/stack/kafka/virtual-machine>>https://bitnami.com/stack/kafka/virtual-machine]]
2.1	25	https://docs.bitnami.com/virtual-machine/infrastructure/kafka/administration/
	26
10.1	27	Виртуальная машина с развернутыми и запущенными [[Apache ZooKeeper>>doc:Разработка.Базы данных.NoSQL.Ключ-значение структура.Apache ZooKeeper.WebHome]] и Kafka.
3.1	28	Username: bitnami
	29	Password: bitnami
	30	В Kafka по умолчанию включена авторизация.
	31
8.6	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}}
8.6	57	)))
	58	\|3) [[ Docker-Compose>>doc:Хостинг.Виртуализация.Docker.Docker-Compose.WebHome]]\|Guide to Setting Up Apache Kafka Using Docker
5.1	59	https://www.baeldung.com/ops/kafka-docker-setup
8.6	60	\|4) Другое\|https://github.com/lensesio/fast-data-dev

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

Приложения

Навигация