Как гарантировать последовательную обработку сообщений в Kafka?