Телеграмм чат группы proKafka страница 1514

parrot.ru

Рейтинг популярных групп и каналов

В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

pro.kafka

1942 membersпожаловаться на группу

2020 September 25

VG

Vik Gamov in pro.kafka

По чесноку нет такой конфлюентовской кафки. Есть кафка которая идет в комьюнити эдишт конфлюент платформы. Она такая же как и АК. Есть Confluent server - это уже кафка прокачанная но он идет за лицензию. Так что CP community или АК разницы нет, это как иметь сборку в rpm виде от redhat или centos

источник

17:09пожаловаться #1

I

IV in pro.kafka

По чесноку нет такой конфлюентовской кафки. Есть кафка которая идет в комьюнити эдишт конфлюент платформы. Она такая же как и АК. Есть Confluent server - это уже кафка прокачанная но он идет за лицензию. Так что CP community или АК разницы нет, это как иметь сборку в rpm виде от redhat или centos

да, я пока в общих чертах ознакомился

источник

17:11пожаловаться #2

V

Vadim in pro.kafka

А confluent server чем как прокачан

источник

18:50пожаловаться #3

lk

leonid khomenko in pro.kafka

А confluent server чем как прокачан

Посмотри что есть в 6.0 . Self rebalance, чёткие метрики в control center

источник

18:59пожаловаться #4

lk

leonid khomenko in pro.kafka

@gamussa собственно вопрос по контрол центер. Пытаемся вынести на отдельный брокер метрики, чтоб шустрее было. Брокеры главного кластера пишут в метрик брокер, всё ок. Но контрол центер не забирает их. По документации не очень ясно, нужно метрик брокер в контрол центер через confluent.controlcenter.kafka.<name>.bootstrap.servers добавлять ?

источник

19:02пожаловаться #5

lk

leonid khomenko in pro.kafka

Как дополнительный кластер для мониторинга

источник

19:03пожаловаться #6

АК

Алексей Кочерев... in pro.kafka

Всем привет, вопрос по тестам kstreams, пишу тест который проходит всю топологию, на вход первого топика даю json объект, внутри топологии делаю join предварительно делаю rekey, и в финальном топике жду измененный json. Могу я при этом просто подать json на вход первого топика и ждать его в финальном?

источник

19:39пожаловаться #7

VG

Vik Gamov in pro.kafka

Алексей Кочерев

Всем привет, вопрос по тестам kstreams, пишу тест который проходит всю топологию, на вход первого топика даю json объект, внутри топологии делаю join предварительно делаю rekey, и в финальном топике жду измененный json. Могу я при этом просто подать json на вход первого топика и ждать его в финальном?

На чем тест? TopologyTestDrver?

источник

19:56пожаловаться #8

VG

Vik Gamov in pro.kafka

> Могу я при этом просто подать json на вход первого топика и ждать его в финальном?
В это и смысл, не?

источник

19:56пожаловаться #9

АК

Алексей Кочерев... in pro.kafka

На чем тест? TopologyTestDrver?

Да

источник

19:57пожаловаться #10

VG

Vik Gamov in pro.kafka

Тогда не вижу никаких проблем

источник

19:57пожаловаться #11

АК

Алексей Кочерев... in pro.kafka

> Могу я при этом просто подать json на вход первого топика и ждать его в финальном?
В это и смысл, не?

Угу, у меня просто по цепочке сообщение не долетает до финального топика, поэтому и решил спросить, может там есть какие то особенности

источник

19:58пожаловаться #12

VG

Vik Gamov in pro.kafka

Алексей Кочерев

Угу, у меня просто по цепочке сообщение не долетает до финального топика, поэтому и решил спросить, может там есть какие то особенности

Значит надо разбить топологию на мелкие и тестировать отдельно. Например как тут
Один тест для Movies, Один для Ratings, и один e2e https://github.com/gAmUssA/streaming-movie-ratings-min-0519/tree/master/src/test/java/io/confluent/demo

gAmUssA/streaming-movie-ratings-min-0519

A small version of of https://github.com/confluentinc/demo-scene/tree/master/streams-movie-demo - gAmUssA/streaming-movie-ratings-min-0519

источник

20:08пожаловаться #13

АК

Алексей Кочерев... in pro.kafka

Значит надо разбить топологию на мелкие и тестировать отдельно. Например как тут
Один тест для Movies, Один для Ratings, и один e2e https://github.com/gAmUssA/streaming-movie-ratings-min-0519/tree/master/src/test/java/io/confluent/demo

gAmUssA/streaming-movie-ratings-min-0519

A small version of of https://github.com/confluentinc/demo-scene/tree/master/streams-movie-demo - gAmUssA/streaming-movie-ratings-min-0519

Спасибо)) будем смотреть

источник

20:11пожаловаться #14

V

VladMl in pro.kafka

Алексей Кочерев

Угу, у меня просто по цепочке сообщение не долетает до финального топика, поэтому и решил спросить, может там есть какие то особенности

Idea отлично умеет дебажить стримы, если это Java

источник

22:17пожаловаться #15

АК

Алексей Кочерев... in pro.kafka

Idea отлично умеет дебажить стримы, если это Java

Котлин) пока не разобрался, спасибо за совет

источник

22:18пожаловаться #16

VG

Vik Gamov in pro.kafka

Idea отлично умеет дебажить стримы, если это Java

Эт как?

источник

22:20пожаловаться #17

DL

Denis Larionov in pro.kafka

Наверное точки останова имеются в виду, на каждом шаге стрима

источник

22:22пожаловаться #18

V

VladMl in pro.kafka

Ставишь бряку и дебажишь

источник

22:22пожаловаться #19

V

VladMl in pro.kafka

Наверное точки останова имеются в виду, на каждом шаге стрима

Да, я так что раз делал

источник

22:26пожаловаться #20