Разница между страницами «Eclipse» и «Kafka»
(Различия между страницами)
Перейти к навигации
Перейти к поиску
FireWolf (обсуждение | вклад) |
FireWolf (обсуждение | вклад) |
||
| Строка 1: | Строка 1: | ||
= | [[:Категория:Работа]] | ||
= Список каналов = | |||
<syntaxhighlight lang="bash"> | <syntaxhighlight lang="bash"> | ||
~/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> | </syntaxhighlight> | ||
= | Вместо прямых IP адресов можно использовать название сервиса: | ||
<syntaxhighlight lang="bash"> | |||
~/work/kafka_2.11-0.10.1.1/bin$ ./kafka-topics.sh --zookeeper telestat-zookeeper:2181 --list | |||
</syntaxhighlight> | |||
- | = Запись в канал = | ||
В консоли каждая строка будет отдельным сообщением в канал | |||
<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> | |||
= Чтение из канала = | |||
- | <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> | |||
[[Категория:Работа]] | |||
Версия 10:23, 28 мая 2018
Список каналов
~/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
Вместо прямых IP адресов можно использовать название сервиса:
~/work/kafka_2.11-0.10.1.1/bin$ ./kafka-topics.sh --zookeeper telestat-zookeeper:2181 --list
Запись в канал
В консоли каждая строка будет отдельным сообщением в канал
~/work/kafka_2.11-0.10.1.1/bin$ ./kafka-console-producer.sh --broker-list 172.18.0.3:9092 --topic telestat-v2-sink
Чтение из канала
~/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