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