Разница между страницами «Kafka» и «JMC»

Материал из Home Wiki
(Различия между страницами)
Перейти к навигации Перейти к поиску
 
 
Строка 1: Строка 1:
[[:Категория:Работа]]
Видео: https://www.youtube.com/watch?v=wm2JNlaJJ5k


= Список каналов =
GIST: https://gist.github.com/aragozin/6ac622de6328a1b6ee58a1bf6f2e523d


<syntaxhighlight lang="bash">
JMC: https://download.oracle.com/otn-pub/java/jmc/7.1.2+04/a4634525489241b9a9e1aa73d9e118e6/jmc-7.1.2_windows-x64.zip
~/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 адресов можно использовать название сервиса:
Для подключения к weblogic нужно докинуть  wlclient.jar, wljmxclient.jar в катоалог с jmc и настроить jmc.ini:
<syntaxhighlight lang="bash">
~/work/kafka_2.11-0.10.1.1/bin$ ./kafka-topics.sh --zookeeper telestat-zookeeper:2181 --list
</syntaxhighlight>


 
<nowiki>
= Запись в канал =
-Djmx.remote.protocol.provider.pkgs=weblogic.management.remote
В консоли каждая строка будет отдельным сообщением в канал
-Djava.naming.factory.initial=weblogic.jndi.WLInitialContextFactory
<syntaxhighlight lang="bash">
-Xbootclasspath/a:wlclient.jar;wljmxclient.jar
~/work/kafka_2.11-0.10.1.1/bin$ ./kafka-console-producer.sh --broker-list 172.18.0.3:9092 --topic telestat-v2-sink
</nowiki>
</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>
 
[[Категория:Работа]]

Версия 12:54, 26 ноября 2020

Видео: https://www.youtube.com/watch?v=wm2JNlaJJ5k

GIST: https://gist.github.com/aragozin/6ac622de6328a1b6ee58a1bf6f2e523d

JMC: https://download.oracle.com/otn-pub/java/jmc/7.1.2+04/a4634525489241b9a9e1aa73d9e118e6/jmc-7.1.2_windows-x64.zip

Для подключения к weblogic нужно докинуть wlclient.jar, wljmxclient.jar в катоалог с jmc и настроить jmc.ini:

-Djmx.remote.protocol.provider.pkgs=weblogic.management.remote -Djava.naming.factory.initial=weblogic.jndi.WLInitialContextFactory -Xbootclasspath/a:wlclient.jar;wljmxclient.jar

Источник — https://wiki.wolf-a.ru/index.php?title=Kafka&oldid=934