Каким образом можно реализовать архитектуру Kafka для гарантированной однократной обработки каждого сообщения?