Я участвую в проекте, чувствительном к задержкам. Он опирается на структуру Kafka Streams, в частности, есть streams
и ktables
, а наиболее популярные операции - leftJoin
, innerJoin
и aggregate
. Возникает вопрос: какие параметры мне нужно настроить, чтобы сделать это как можно быстрее, кроме topi c разметки?
Итак, я спрашиваю:
- Как сделать агрегацию быстрой?
- Как сделать
stream x stream
быстрой? - Как сделать
stream x ktable
быстро? - Как сделать
ktable x ktable
быстрым? - Какие соответствующие собственные метрики, на которые я могу положиться, чтобы без дополнительных усилий измерить производительность Kafka Streams?
PS Предположим, что обратные вызовы, передаваемые в эти операции, выполняются мгновенно.