Partitioning with key

[arezvani]

How can I partitioning with key? If I use fieldpartitioner, partition.field.name should be set to which value? And if I want to partitioning my data with key and hold just latest 10 minutes or 10 data for each key, what should I do?

[OneCricketeer]

Field partitioner only inspects the value of each record.

Therefore, you'd need another transform, or stream processor before being able to partition after moving the key to the value. Or otherwise duplicate the key into the value during producer code.