Блог

я новичок, использующий друида и кафку.

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

Заранее благодарю

Это зависит:

• о вашем размере сообщений Кафки
• от мощности вашего производителя и скорости передачи сообщений Кафке
• на серверах вашего Кафки, разделение и множество других факторов.
• в модели развертывания вашего друида (одного или кластера)
• и….

Но самое важное, чего мне здесь не хватает, — это количество ваших задач, что означает объем параллельной обработки (а поскольку вы Кафка, это означает параллельных потребителей). Увеличьте его и убедитесь, что у вашего хоста Druid (или хоста среднего менеджера, если это кластер) достаточно ядер для ваших задач. И убедитесь, что в вашем менеджере среднего звена вы увеличили общее количество доступных задач: druid.worker.capacity