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

Вроде, в самом докладе есть плюсы и минусы
На сколько я понял, плюсы в том, что работает на 2 ДЦ с возможностью потерять любой
Минусы, что потребуются ручные действия при фейловере

источник

23:36пожаловаться #5

2020 January 20

s

step.kh in pro.kafka

У кого-нибудь есть опыт поднятия kafka с sasl plaintext? Столкнулся с трудностью проверки работоспособности поднятого. Failed to authentication, как будто бы клиенту я не даю логин/пароль.

источник

09:48пожаловаться #6

D

Dmitry in pro.kafka

step.kh

У кого-нибудь есть опыт поднятия kafka с sasl plaintext? Столкнулся с трудностью проверки работоспособности поднятого. Failed to authentication, как будто бы клиенту я не даю логин/пароль.

Есть. Опиши подробно

s

Есть. Опиши подробно

https://pastebin.com/RkssaNkz

Pastebin

config/server.properties sasl.enabled.mechanisms=PLAIN security.inter.broker.p - Pastebin.com

источник

11:39пожаловаться #8

s

step.kh in pro.kafka

zookeeper без авторизации.

источник

11:39пожаловаться #9

s

step.kh in pro.kafka

Забыл добавить в файл саму команду: bin/sasl-kafka-topics.sh --create --bootstrap-server localhost:9094 --replication-factor 1 --partitions 1 --topic my-topic

источник

11:46пожаловаться #10

D

Dmitry in pro.kafka

как минимум

sasl.enabled.mechanisms=SCRAM-SHA-256,PLAIN
sasl.mechanism.inter.broker.protocol=SCRAM-SHA-256
ssl.endpoint.identification.algorithm=

источник

12:02пожаловаться #11

D

Dmitry in pro.kafka

притом у меня в примере sasl.enabled.mechanisms=SCRAM-SHA-256,PLAIN - PLAINT отвечает за доступ без аутентификауции

источник

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

D

Dmitry in pro.kafka

т.е. я могу попасть на кластер напрямую или через SASL по разным портам

источник

12:16пожаловаться #13

D

Dmitry in pro.kafka

у меня есть полноценная "статья", если надо - скину

источник

12:17пожаловаться #14

N

Nikolay in pro.kafka

Скиньте мне статью плиз , как настроить простой ssl для Кафки

источник

12:25пожаловаться #15

D

Dmitry in pro.kafka

За ssl в гугл)

источник

12:26пожаловаться #16

D

Dmitry in pro.kafka

хотя, я сегодня искал статью для настройки SSL между кафкой и зукипером и там был пример, как и клиентов тоже настроить
поэтому вот - https://juplo.de/encrypt-communication-between-kafka-and-zookeeper-with-tls/

источник

12:39пожаловаться #17

s

step.kh in pro.kafka

Dmitry

у меня есть полноценная "статья", если надо - скину

Был бы признателен.

источник

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

ὦ

ὦan in pro.kafka

Добрый вечер, вопрос. Объявил кафке serializer и desializer, чтобы она могла в сущность переводит сообщение
https://pastebin.com/8jPgjmJm
и получаю в лицо

A serializer (key: org.apache.kafka.common.serialization.LongSerializer / value: org.apache.kafka.common.serialization.StringSerializer) is not compatible to the actual key or value type (key type: java.lang.Long / value type: su.moneycare.service.proxy.kafka.Message).

Не для того я объявлял все это, чтобы такого не получать?)

Pastebin

KStreamBuilder builder = new KStreamBuilder();

Map<String, Object> serdePro - Pastebin.com

источник

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

NR

Nikita Ryanov in pro.kafka

ὦan

Добрый вечер, вопрос. Объявил кафке serializer и desializer, чтобы она могла в сущность переводит сообщение
https://pastebin.com/8jPgjmJm
и получаю в лицо

A serializer (key: org.apache.kafka.common.serialization.LongSerializer / value: org.apache.kafka.common.serialization.StringSerializer) is not compatible to the actual key or value type (key type: java.lang.Long / value type: su.moneycare.service.proxy.kafka.Message).

Не для того я объявлял все это, чтобы такого не получать?)

Pastebin

KStreamBuilder builder = new KStreamBuilder();

Map<String, Object> serdePro - Pastebin.com

Могу ошибаться, но вы переоопределили дефолтный serde только для получения данных, но не переорпделелили его для отправки

источник

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