This performance testing framework evaluates the maximum throughput of a Kafka cluster, and compares the put latency of different broker, producer, and consumer configurations. To run a test, you need ...

In Pyper, the task decorator is used to transform functions into composable pipelines. Let's simulate a pipeline that performs a series of transformations on some data.