Есть кто, кто работал с sarama (kafka)? проблема в том,

Question

Go-go!

Alexander

Есть кто, кто работал с sarama (kafka)? проблема в том,

что при аутентификации чрез ssl consumerCroup молча не принимает сообщения...

#backend #go #programming #russian

0

25.09.2020

8 ответов

14 просмотров

Alexander Автор вопроса

Andrei 🦉 Sergeev
проверьте, что у вас идут сообщения в топик, либо ...

в топик идут. рядом sarama.NewConsumerFromClient - отрабатывает и получает их. но sarama.NewConsumerGroupFromClient("mgn", *cl) - молчалив. в канале ошибок последнего - тоже нет ничего

0

25.09.2020

Andrei 🦉 Sergeev

Alexander
в топик идут. рядом sarama.NewConsumerFromClient -...

группа разная? партиций в топике больше одной?

0

25.09.2020

Alexander Автор вопроса

Andrei 🦉 Sergeev
группа разная? партиций в топике больше одной?

группа чего? они запущены по-отдельности. не в один момент. к тому же - второй это просто partiotionConsumer/ партиция - одна, проверил только что.

0

25.09.2020

Andrei 🦉 Sergeev

Alexander
группа чего? они запущены по-отдельности. не в оди...

ну если они по разному реализованы, то работа одного рз них ничего не говорит советую тестировать включение ssl на том же коде, что и без ssl, а так вы могли просто в коде накосячить

0

25.09.2020

Alexander Автор вопроса

Andrei 🦉 Sergeev
ну если они по разному реализованы, то работа одно...

- по-разному в коде либы? да, отличия есть, это же разные консюмераы. но базируются на 1 клиенте. - работа одного не говорит. но у меня проблема, что мне нужен второй, а он как раз не работает) - при sasl_plain - этот код работает. к тому же отличие только в sarama.Config - а он один и для partitionConsumer и для consumerGroup(

0

25.09.2020

Andrei 🦉 Sergeev

Alexander
- по-разному в коде либы? да, отличия есть, это же...

ну в любом случае гораздо более вероятно, что косяк в вашем коде, чем коде самой популярной либы для кафки самый простой вариант для проверки - это запустить проблемный консьюмер без ssl, и уже от результатов плясать

0

25.09.2020

Alexander Автор вопроса

Andrei 🦉 Sergeev
ну в любом случае гораздо более вероятно, что кося...

как я и написал - результат работает) я и не говорю, что проблема точно у них. всегда остается вариант, что я не правильно их использую. да и куча вариантов. но и исключать это неправильно было бы. я не знаю, где проблема. но если кто-то точно знает, что такая конфигурация работает или мог бы прокомментировать - это бы помогло)

0

25.09.2020

Andrei 🦉 Sergeev · Accepted Answer

Andrei 🦉 Sergeev

проверьте, что у вас идут сообщения в топик, либо поставьте в настройках чтение с начала топика

0

25.09.2020

170 похожих чатов

Есть кто, кто работал с sarama (kafka)? проблема в том,

8 ответов

Похожие вопросы