more flexible for kafkatest