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