Я написал рабочую службу для приема сообщений из очереди Kafka, а также написал тестовый скрипт для добавления сообщений в очередь каждые несколько секунд.
Что я заметил, так это то, что часто потребитель простаивает в течение нескольких минут, в то время как сообщения добавляются в очередь. Затем внезапно потребитель подберет первое сообщение, обработает его, а затем быстро перейдет к остальным. Так что в конце концов это догоняет, но мне интересно, почему вообще такая задержка?
