В Apache Kafka доставка сообщений потребителю гарантируется через механизм подтверждений (acknowledgments) и управление смещениями (offsets). Если сообщение не было успешно обработано потребителем, то:

Потребитель не подтверждает (не коммитит) смещение, связанное с этим сообщением.
При повторном запуске или повторном чтении топика потребитель сможет прочитать это сообщение снова, так как смещение не было сдвинуто.

Kafka сама по себе не отслеживает успешность обработки сообщений на стороне потребителя — это ответственность клиента. Обычно потребители используют ручное управление смещениями (manual commit), чтобы подтверждать обработку только после успешной обработки сообщения.

Если сообщение не обработано, оно остается доступным для повторного чтения. Также можно настроить повторные попытки обработки и использовать механизмы Dead Letter Queue (DLQ) для сообщений, которые не удалось обработать после нескольких попыток.

Пример на Java с ручным коммитом смещений:

ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
for (ConsumerRecord<String, String> record : records) {
    try {
        process(record.value());
        consumer.commitSync(Collections.singletonMap(new TopicPartition(record.topic(), record.partition()),
            new OffsetAndMetadata(record.offset() + 1)));
    } catch (Exception e) {
        // Обработка ошибки, сообщение не подтверждается, будет прочитано повторно
    }
}

Как Kafka обрабатывает ситуации, когда сообщение не было успешно доставлено потребителю?