Size: a a a

2020 March 03

A

Anatoly Soldatov in pro.kafka
Игорь
Хранятся так как прислал продьюсер
Они могут храниться в сжатом виде
Либо как прислал продюсер,  либо пережать с параметрами для конкретного топика на самом брокере (доп работа)
источник

A

Anatoly Soldatov in pro.kafka
Сжатие можно включить и на продюсере и на брокере
источник

DS

Dastan S in pro.kafka
Anatoly Soldatov
Сжатие можно включить и на продюсере и на брокере
На брокере это какой конфиг?
источник

A

Anatoly Soldatov in pro.kafka
Dastan S
На брокере это какой конфиг?
compression.type
источник

A

Anatoly Soldatov in pro.kafka
источник

A

Anatoly Soldatov in pro.kafka
Кстати, @gamussa, подскажи, плиз, почему отсутствие сжатия на продюсере это none, а на уровне топика это uncompressed ?:) всегда было интересно почему не сделали одинаковый нейминг
источник

VZ

Vladimir Zemtsov in pro.kafka
Добрый день.Можете подсказать с одной проблемой.

Имеется 3х нодный кластер кафки. В server.properties:
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://192.168.1.1(/2/3):9092


Все отлично работает. Брокеры доступны, сообщени пишутся, сообщения читаются.

Но мне понадобилось организоваться внешний доступ к kafka (Из другой подсети).
Был организован доступ между сетями на одном брокере я поменял конфиги на:
listeners=INTERNAL://0.0.0.0:9092,EXTERNAL://0.0.0.0:9093
advertised.listeners=INTERNAL://192.168.1.1:9092,EXTERNAL://192.168.100.1:9093
inter.broker.listener.name=INTERNAL
listener.security.protocol.map=INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT


однако когда стартуешь кафку с такими настройками в логах повторяющиеся ошибки:
WARN [Consumer clientId=consumer-1, groupId=console-consumer-29699] Error while fetching metadata with correlation id 171 : {topic=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)


Если проверять состояние кластера через зукипер - ошибок не видно.
Можете подсказать что я делаю не так?
источник

GG

George Gaál in pro.kafka
На всех надо менять
источник

VZ

Vladimir Zemtsov in pro.kafka
Нету возможности на всех поменять, указав один и тот же EXTERNAL endpoint. Иначе возникает ошибка:

failed: Configured end points 192.168.100.1:9093 in advertised listeners are already registered by broker 0
источник

GG

George Gaál in pro.kafka
Vladimir Zemtsov
Нету возможности на всех поменять, указав один и тот же EXTERNAL endpoint. Иначе возникает ошибка:

failed: Configured end points 192.168.100.1:9093 in advertised listeners are already registered by broker 0
А почему один адрес на всех, они у тебя за лб, что ли ?
источник

GG

George Gaál in pro.kafka
Лб - load balancer
источник

VZ

Vladimir Zemtsov in pro.kafka
Именно.
Доступ между сетями организован через прокси-ноду и там лб до Кафки
источник

GG

George Gaál in pro.kafka
Из того что я знаю - это кривая конфа (
источник

GM

Gleb Mekhrenin in pro.kafka
с кафкой так нельзя
источник

GM

Gleb Mekhrenin in pro.kafka
ну в смысле сделать то можно, но хорошего ничего не будет
источник

VZ

Vladimir Zemtsov in pro.kafka
Понял вас.

Я могу настроить второй и третий брокер на какой-нибудь левый EXTERNAL endpoint, на который никогда не будут приходить запросы и заработает?
источник

GG

George Gaál in pro.kafka
Нет
источник

GG

George Gaál in pro.kafka
Правильный сценарий - если ты хочешь две Кафки
источник

GG

George Gaál in pro.kafka
И между ними штука, которая уметь ходить в обе и синхрить - либо миррор мейкер, либо что-то свое
источник

GG

George Gaál in pro.kafka
Можешь поггулить - Кафка за лб это не очень поддерживаемый сценарий, Кафка сама балансирует запросы
источник