Каким образом происходит извлечение и удаление сообщений из очереди Kafka после их обработки?