Differences

This shows you the differences between two versions of the page.

--- giganet:sflow [2021/08/02 13:36]
rb [switch]
+++ giganet:sflow [2021/08/03 13:28] (current)
rb
@@ Line 1: / Line 1: @@
-====== Схема мониторинга sflow статистики ======
-===== Задействованные сервера =====
-  * **goflow **- сервер на котором крутится kafka и goflow2 приложение по сбору статистики
-  * **clickhouse **- сервер с базой данных clickhouse, хранение и обработка статистики
-===== Задействованные приложения =====
-  * **goflow2**
-  * **kafka**
-  * **clickhouse**
 ===== Общая схема мониторинга =====
@@ Line 36: / Line 25: @@
 </code>
 ==== goflow2 ====
@@ Line 48: / Line 36: @@
 ==== kafka ====
+== Установка ==
+<code>
+useradd kafka -m
+passwd kafka
+su -l kafka
+cd
+curl https://archive.apache.org/dist/kafka/2.8.0/kafka_2.13-2.8.0.tgz -O kafka_2.13-2.8.0.tgz
+tar -xvzf kafka_2.13-2.8.0.tgz
+ln -s  /home/kafka/kafka_2.13-2.8.0 /home/kafka/kafka
+</code>
+/home/kafka/kafka/config/server.properties
+<code>
+delete.topic.enable=true
+</code>
+/etc/systemd/system/zookeeper.service
+<code>
+[Unit]
+Requires=network.target remote-fs.target
+After=network.target remote-fs.target
+[Service]
+Type=simple
+User=kafka
+ExecStart=/home/kafka/kafka/bin/zookeeper-server-start.sh /home/kafka/kafka/config/zookeeper.properties
+ExecStop=/home/kafka/kafka/bin/zookeeper-server-stop.sh
+Restart=on-abnormal
+[Install]
+WantedBy=multi-user.target
+</code>
+/etc/systemd/system/kafka.service
+<code>
+[Unit]
+Requires=zookeeper.service
+After=zookeeper.service
+[Service]
+Type=simple
+User=kafka
+ExecStart=/bin/sh -c '/home/kafka/kafka/bin/kafka-server-start.sh /home/kafka/kafka/config/server.properties> /home/kafka/kafka/kafka.log 2>&1'
+ExecStop=/home/kafka/kafka/bin/kafka-server-stop.sh
+Restart=on-abnormal
+[Install]
+WantedBy=multi-user.target
+</code>
+Запускаем сервисы
+<code>
+systemctl daemon-reload
+systemctl start kafka
+systemctl enable kafka
+</code>
+Работаем с kafka
 <code>
@@ Line 63: / Line 120: @@
 [[https://github.com/netsampler/goflow2/blob/main/pb/flow.proto|https://github.com/netsampler/goflow2/blob/main/pb/flow.proto]] \\
 [[https://clickhouse.tech/docs/ru/engines/table-engines/integrations/kafka/|https://clickhouse.tech/docs/ru/engines/table-engines/integrations/kafka/]] \\
-https://github.com/AlexeyKupershtokh/clickhouse-maxmind-geoip/ \\
+[[https://github.com/AlexeyKupershtokh/clickhouse-maxmind-geoip/|https://github.com/AlexeyKupershtokh/clickhouse-maxmind-geoip/]] \\
-https://gist.github.com/sanchezzzhak/511fd140e8809857f8f1d84ddb937015
+[[https://gist.github.com/sanchezzzhak/511fd140e8809857f8f1d84ddb937015|https://gist.github.com/sanchezzzhak/511fd140e8809857f8f1d84ddb937015]]
 === таблица kafka ===
@@ Line 230: / Line 287: @@
 PARTITION BY toYYYYMMDD(Date)
 ORDER BY Datetime
-TTL Date + toIntervalDay(7)
+TTL Date   toIntervalDay(7)
 SETTINGS index_granularity = 8192

R.B. wiki

User Tools

Site Tools

Differences

Page Tools