Интеллектуальное автомасштабирование потребителей Kafka с прогнозированием рабочей нагрузки
В приложении на основе Kafka сообщения для определенных тем генерируются некоторыми производителями и отправляются брокерам Kafka. Брокеры выполняют необходимые репликации и распространяют сообщения среди потребителей соответствующих тем. После получения сообщений от брокеров потребитель выполняет некоторые задачи и сообщает брокерам, что сообщения были зафиксированы (или потреблены). Смотрители хранят смещение последнего сообщения, отправленного производителем для темы, и смещение последнего зафиксированного сообщения, сообщенного потребителем для темы...