|
|
| Строка 1: |
Строка 1: |
| [[:Категория:Работа]] | | [[:Категория:Работа]] |
|
| |
|
| = Список каналов = | | = Ссылки = |
|
| |
|
| <syntaxhighlight lang="bash">
| | [https://angular.io/guide/architecture#component-code Tutorial] |
| ~/work/kafka_2.11-0.10.1.1/bin$ ./kafka-topics.sh --zookeeper 172.18.0.5:2181 --list
| |
| __consumer_offsets
| |
| telestat-v2-sink
| |
| topic-jhipster
| |
| </syntaxhighlight>
| |
|
| |
|
| Вместо прямых IP адресов можно использовать название сервиса:
| | [https://angular.io/guide/styleguide#separate-file-names-with-dots-and-dashes Stule Guide] |
| <syntaxhighlight lang="bash">
| |
| ~/work/kafka_2.11-0.10.1.1/bin$ ./kafka-topics.sh --zookeeper telestat-zookeeper:2181 --list
| |
| </syntaxhighlight>
| |
|
| |
|
| | = Оптимизация = |
|
| |
|
| = Запись в канал =
| | [https://blog.thoughtram.io/angular/2017/02/02/making-your-angular-app-fast.html] |
| В консоли каждая строка будет отдельным сообщением в канал
| |
| <syntaxhighlight lang="bash">
| |
| ~/work/kafka_2.11-0.10.1.1/bin$ ./kafka-console-producer.sh --broker-list 172.18.0.3:9092 --topic telestat-v2-sink
| |
| </syntaxhighlight>
| |
|
| |
|
| = Чтение из канала =
| | [https://blog.thoughtram.io/angular/2017/02/02/making-your-angular-app-fast.html#detach-change-detectors-from-change-detector-tree] |
| | |
| <syntaxhighlight lang="bash">
| |
| ~/work/kafka_2.11-0.10.1.1/bin$ ./kafka-console-consumer.sh --bootstrap-server 172.18.0.3:9092 --topic telestat-v2-sink --from-beginning
| |
| </syntaxhighlight>
| |
| | |
| = Статьи =
| |
| | |
| http://dotsandbrackets.com/highly-available-kafka-cluster-docker-ru/
| |
| | |
| https://sematext.com/blog/monitoring-kafka-on-docker-cloud/
| |
| | |
| = Построение кластера =
| |
| Пример kafka-cluster.yml для одного хоста, у другого будет все аналогично, за исключением KAFKA_BROKER_ID и KAFKA_ADVERTISED_HOST_NAME
| |
| | |
| Можно поменять порядок хостов в KAFKA_ZOOKEEPER_CONNECT.
| |
| | |
| KAFKA_BROKER_ID можно не указывать, он настроится автоматически.
| |
| | |
| <syntaxhighlight>
| |
| version: '2'
| |
| services:
| |
| kafka-cluster:
| |
| container_name: kafka-cluster
| |
| image: wurstmeister/kafka:1.0.0
| |
| environment:
| |
| ## NB! SET KAFKA_BROKER_ID UNIQUE PER HOST
| |
| KAFKA_BROKER_ID: 1
| |
| KAFKA_ADVERTISED_HOST_NAME: kafka1
| |
| KAFKA_ADVERTISED_PORT: 9092
| |
| KAFKA_ZOOKEEPER_CONNECT: zoo1:2183,zoo2:2183,zoo3:2183
| |
| # KAFKA_CREATE_TOPICS: "telestat-v2-sink:1:2,prozvon-sink:1:2,teledemo-v2-sink:1:2"
| |
| KAFKA_LOG_DIRS: /kafka/kafka-logs
| |
| ports:
| |
| - 9092:9092
| |
| restart: always
| |
| extra_hosts:
| |
| - "zoo1:192.168.1.8"
| |
| - "zoo2:192.168.1.7"
| |
| - "zoo3:192.168.1.6"
| |
| volumes:
| |
| - /opt/docker/kafka/:/kafka/
| |
| </syntaxhighlight>
| |
|
| |
|
| [[Категория:Работа]] | | [[Категория:Работа]] |
| | [[Категория:TrueScript]] |
| | [[Категория:JHipster]] |