You might want to be more specific about how messages are assigned to clients than what would be convenient in a relational database.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-932%3A...