Size: a a a

2020 November 13

EL

Evgeny Lazin in pro.kafka
Так это же в платной версии confluent, разве нет?
источник

GK

Gregory Koshelev in pro.kafka
Это KIP в Кафке.
источник

GK

Gregory Koshelev in pro.kafka
К Confluent не имеет никакого отношения. Совсем. 🙂
источник

GK

Gregory Koshelev in pro.kafka
Вообще, странно ожидать, что на сайте Apache будут рекламировать какой-то проприетарный софт 🙂
источник

EL

Evgeny Lazin in pro.kafka
Sergei Egorov
у них есть CLI для старта кластера на основе докера, я подозреваю оно использует Docker образы внутри
Есть rpk, который умеет запускать кластер. Докер используется на маке, в Линукс, оно должно работать наивно.
источник

SE

Sergei Egorov in pro.kafka
Gregory Koshelev
Вообще, странно ожидать, что на сайте Apache будут рекламировать какой-то проприетарный софт 🙂
ой, да лааааааааадно
источник

SE

Sergei Egorov in pro.kafka
дайте знать когда у кафки появится оффициальный Docker образ
источник

EL

Evgeny Lazin in pro.kafka
Я просто очень поверхностно знаком с какой, поэтому хз. Kip это же просто дизайн документ. В oss кафке он реализован уже?
источник

GK

Gregory Koshelev in pro.kafka
Sergei Egorov
дайте знать когда у кафки появится оффициальный Docker образ
Так вы намёков не понимаете: не надо хранилки в докер пихать. 🙂
источник

GK

Gregory Koshelev in pro.kafka
Evgeny Lazin
Я просто очень поверхностно знаком с какой, поэтому хз. Kip это же просто дизайн документ. В oss кафке он реализован уже?
Так только OSS Кафка и существует. Confluent своими сервисами обмазывает + инструментами для работы.
источник

ЮХ

Юра Ходырев... in pro.kafka
Gregory Koshelev
Так вы намёков не понимаете: не надо хранилки в докер пихать. 🙂
Вроде как всякие Фланты и прочие чуваки, которые кубер рекламируют, говорят, что хранилки в докер это нормально))
источник

ЮХ

Юра Ходырев... in pro.kafka
Такая хандра была года 3-4 назад
источник

NK

Nikita Konev in pro.kafka
Sergei Egorov
дайте знать когда у кафки появится оффициальный Docker образ
в моём понимании это как ядро линух - вот тар гз, сиди собирай)
готовые ядра у дистрибутивов

тут также сама кафка - сорцы на гитхабе
нужен готовый образ - конфлюент коммьюнити образ

---
хотя могу ошибаться
источник

PR

Paul Reshetnikov in pro.kafka
Всем доброй пятницы! Подскажите плиз, ЧЯДНТ?  

Компоуз с кафкой (кусок)
..........кафка.............
 environment:
     KAFKA_BROKER_ID: 1
     KAFKA_ZOOKEEPER_CONNECT: "zookeeper:${ZOOKEEPER_PORT}"
     KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT_HOST:PLAINTEXT,PLAINTEXT:PLAINTEXT
     KAFKA_ADVERTISED_LISTENERS: PLAINTEXT_HOST://kafka:${KAFKA_PORT},PLAINTEXT://kafka:${KAFKA_PORT_20K}
     KAFKA_LISTENERS: PLAINTEXT_HOST://0.0.0.0:${KAFKA_PORT},PLAINTEXT://0.0.0.0:${KAFKA_PORT_20K}
.................

в своём сервисе:
KAFKA_BOOTSTRAP_SERVERS: '${HOST_IP}:${KAFKA_PORT},kafka:${KAFKA_PORT_20K}'


результат:

|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT)


всю голову сломал уже...
источник

ЮХ

Юра Ходырев... in pro.kafka
localhost:9092/bootstrap - тут скорее всего должно быть название контейнера в котором брокер лежит из композа
источник

ЮХ

Юра Ходырев... in pro.kafka
В AFKA_ADVERTISED_LISTENERS надо смотреть, что прописано
источник

ЮХ

Юра Ходырев... in pro.kafka
Продюсер при подключении по бутстрап адресу вычитывает из zoo KAFKA_ADVERTISED_LISTENERS и пытается по этим значениям стучать
источник

PR

Paul Reshetnikov in pro.kafka
Юра Ходырев
В AFKA_ADVERTISED_LISTENERS надо смотреть, что прописано
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT_HOST://kafka:${KAFKA_PORT},PLAINTEXT://kafka:${KAFKA_PORT_20K}
источник

PR

Paul Reshetnikov in pro.kafka
Юра Ходырев
Продюсер при подключении по бутстрап адресу вычитывает из zoo KAFKA_ADVERTISED_LISTENERS и пытается по этим значениям стучать
т.е. в теории вот это должно сработать?
KAFKA_BOOTSTRAP_SERVERS: kafka:${KAFKA_PORT},kafka:${KAFKA_PORT_20K}
источник

ЮХ

Юра Ходырев... in pro.kafka
PLAINTEXT_HOST://kafka:${KAFKA_PORT} - судя по всему берется вот это значение и оно = localhost:9092
источник