возможно ли, что С# драйвер ещё не умеет передавать параметры эти?

возможно, но странно потому что в примере они указаны

какая версия кафки?

max poll records появилось вроде только в 0.10 или 0.10.1

странно что разработчики сами не могут этого загуглить, и сваливают на админа ))

странно что разработчики сами не могут этого загуглить, и сваливают на админа ))

Если на девопса, то можно

Если на девопса, то можно

тогда девопсы вредны

Если на девопса, то можно

сваливать на девопса как из кода разрабов разрабам вызывать что-то? даунизм

max poll records появилось вроде только в 0.10 или 0.10.1

10,2,1

тогда разрабы какую-то херню делают и сами долбоебы, мы используем, всё работает

тогда разрабы какую-то херню делают и сами долбоебы, мы используем, всё работает

с С# драйвером?

видимо да

у меня вот есть мысль, что в драйвер С# ещё не завезли

а вы с зоокипером используете кафку, или без?

я показал ссылку на ту что давали, дал картинку

на меня наорали, что они это читали, так же почти вызывают, ток из примера для С/#

долбоёбы, сэр

и у них кафка отвеает, что параметров нет

говорят, что я просто недокрутил на сервере

Ну хз, может версия драйвера очень старая

блять, там не надо ничего крутить на сервере

это КЛИЕНТСКИЕ проперти

говорят, что я просто недокрутил на сервере

конкретно для тебя решение простое надо продемонстировать что работает, не важно на чем, пусть на java

Ну хз, может версия драйвера очень старая

они мне утверждают, что драйвер гениален, тк на С#, он чисто прослойка и тупо передаёт параметры, и им чётко идёт ответ, что нет параметра

конкретно для тебя решение простое надо продемонстировать что работает, не важно на чем, пусть на java

Да по его рассказам похоже там аутисты работают какие-то в роли разработчиков

а раз ответ, чёткий и что нет параметра, значит я его не включил

либо найти им статью, где авторитетный С# разраб говорит, что он не работает

Оно никуда не идет. ты настраиваешь клиента. никакие параметры от клиента к серверу не идут

а вы с зоокипером используете кафку, или без?

А че кафку можно без зукипера?)

вариант что драйвер старый и не поддерживает эту проперти вполне реальный и самый вероятный

А че кафку можно без зукипера?)

да, но я правда не понял как

вариант что драйвер старый и не поддерживает эту проперти вполне реальный и самый вероятный

а что тогда делает драйвер?если он к серверу не обращается

вот видимо я тупоц, но я не понимаю, как тогда это работает

а что тогда делает драйвер?если он к серверу не обращается

Он не передает на сервер свойства которые ты ему конфигурируешь. это конфигурация клиента

вот предположим, я задам параметры, далее они куда и как пойдут?

сервер понятия не имеет что у какого-то клиента max.poll.records 10 а у другого 20, это дело клиента

эти параметры используются только при конфигурации самого клиента

чем занимается драйвер?

я тогда его смысл не понимаю

тем что подключается к серверу используя протокол кафки и может делать какие-то вызовы - читать сообщения итд

вот мне как devops, что нужно в кафки накрутить, чтобы разрабы могли использовать все параметры?

это клиентская библиотека, драйвером называть это наверное некорректно

ничего

Это параметры клиента, у сервера свои настройки, всё в доках детально по секциям расписано

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

наш софт?

код, который вызывает клиентскую библиотеку кафки

да

ваш софт

как мне сейчас сказали

да, типа это клиентская штука

но когда клиент обращается к кафке он типа хочет 10 буханок ъхлеба, а ему дают 2

у клиента в конфиге 10, как он говорит кафке, что надо ему дать 10 а не 2 буханки

вот так мне сейчас сказали

Лол

?

Лол

ну вот собственно на самом деле, если клиент хочет например не 10 буханок а 50 или наоборот хочет 3 тбуханки а не 10

как он сообщает это кафке?

?хотят чтобы я это им узнал

если буханок всего 2, то 10 клиент никак не получит

=)

https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol

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

как он сообщает это кафке?

ConsumerRecords<String, String> records = consumer.poll(Long.MAX_VALUE);

как иначе?

если буханок всего 2, то 10 клиент никак не получит

а если буханок 20к, а клиенту надо 3?

ERROR: S client not available

у клиента есть настройка: сколько считывать

то он попросит только 3 буханки, в следующий раз еще 3 и т.д.

тогда зачем нужен макпул?

чтобы читать по максимуму

например, у вас льется огромное ко-во сообщений и надо их быстрее разобрать

работает 10 косьюмеров, каждый берет сколько успеет

тогда зачем нужен макпул?

какой пул? откуда вдруг пул появился

какой пул? откуда вдруг пул появился

consumer.poll(Long.MAX_VALUE); он про это, скорее всего

а-а, пол

@erzentd , вам верную идею подсказали: попробовать запустить приложение на джаве и доказать, что читать можно сколько угодно (сколько в клиенте установили)

макпул — новый макдачный бургер

@erzentd , кидали им https://kafka.apache.org/documentation/#consumerconfigs ?

?

https://github.com/apache/kafka/blob/2572637121527f8c37bc95212e7eaf8190eb436b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java#L515

собственно все здесь

мне заявили, что у них в клиенте 2 строчки из примера, и эти параметры передаются кафке

как где то описано

мне заявили, что у них в клиенте 2 строчки из примера, и эти параметры передаются кафке

что значит "передаются кафке"?

это же настройки клиента

типа так где то было в доке на конфлюенсе написано

а они уверены, что в топике достаточно данных? партиций установлено приемлимое количество? что они читают именно 2, а не 10?

сисярпопроблемы

Ну тебе уже тут несколько человек сказали что настройки клиента никуда не передаются брокеру )) походу твои "коллеги" увидели слово какое-то в конфлюенте и начали нести чушь, не разобравшись

Ну тебе уже тут несколько человек сказали что настройки клиента никуда не передаются брокеру )) походу твои "коллеги" увидели слово какое-то в конфлюенте и начали нести чушь, не разобравшись

http://docs.confluent.io/current/clients/consumer.html

тут сказали типа сказано иное

Хз, я умываю руки, второй день твердить одно и то же

Хз, я умываю руки, второй день твердить одно и то же

ну я админ, передаю слвоа разрабов

я объясняю, они не слушают

Долбоебы, сэр

Пусть они сами сюда придут, поясним им за жизнь

я вообще в шоке, с пхпшниками проще было

я вообще в шоке, с пхпшниками проще было

покажите им доку с настройками для брокера