Настройка потоков Kafka на задержку - PullRequest
0 голосов
/ 05 мая 2020

Я участвую в проекте, чувствительном к задержкам. Он опирается на структуру Kafka Streams, в частности, есть streams и ktables, а наиболее популярные операции - leftJoin, innerJoin и aggregate. Возникает вопрос: какие параметры мне нужно настроить, чтобы сделать это как можно быстрее, кроме topi c разметки?

Итак, я спрашиваю:

  1. Как сделать агрегацию быстрой?
  2. Как сделать stream x stream быстрой?
  3. Как сделать stream x ktable быстро?
  4. Как сделать ktable x ktable быстрым?
  5. Какие соответствующие собственные метрики, на которые я могу положиться, чтобы без дополнительных усилий измерить производительность Kafka Streams?

PS Предположим, что обратные вызовы, передаваемые в эти операции, выполняются мгновенно.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...