Я пытаюсь написать потребителя Kafka, где я передаю все документы в теме.И я хочу закрыть потребителя Kafka, как только все документы будут использованы, и у меня нет других документов для потребления.
Проблема в том, что потребитель должен постоянно читать и никогда не останавливаться, есть ликаким путем я могу узнать, что все записи в теме Кафки были использованы и переданы, чтобы я мог закрыть своего потребителя?