Kafka partitionable operator benchmark app #245