Я построил потребителя, используя Kafka Consumer API, способ, которым этот потребитель должен работать, - это выборка 'n' сообщений из темы и их обработка одновременно, и каждый поток затем фиксирует смещение для сообщения, которое он имеет обработанный . Таким образом, вызов poll () в API зависит от установленного времени. Есть ли способ опроса () для следующего пакета только после того, как все потоки обработали предыдущий пакет и зафиксировали смещение?