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