Насколько я знаю, потребитель kafka может использовать API poll () только для получения сообщений от брокера, однако мы знаем, что мы также можем использовать API высокого / низкого уровня kafka для получения сообщений от брокера, так какова связь между kafka пользовательский API высокого / низкого уровня и опрос API ()? Пользовательский API высокого / низкого уровня вызывает внутри? Poll ()?
Как API высокого / низкого уровня kafka получает сообщения от брокера?
Ответы (1)
Потребители высокого / низкого уровня - это так называемые старые потребители, которые реализованы в Scala. Потребители с API опросов - это новые потребители, полностью написанные на Java.
Старые потребители скоро будут упразднены, и теперь рекомендуются новые потребители.
person
amethystic
schedule
16.05.2017
Спасибо за разъяснения, xiexie :-)
- person YuFeng Shen; 16.05.2017
@ Джейсон букэки ~~
- person amethystic; 16.05.2017
Кстати, для старых потребителей высокого уровня, как показано ниже, как он получает сообщения от брокера, разве он не использует poll () для получения сообщения? cwiki.apache.org/confluence/display/KAFKA/
- person YuFeng Shen; 16.05.2017
Сложно объяснить все в нескольких предложениях. Проще говоря, оба потребителя соблюдают способ, при котором клиенты отправляют запросы FETCH брокерам, а брокеры отвечают на эти запросы. Однако старые потребители используют для этого несколько потоков.
- person amethystic; 16.05.2017
