Duplicate code in KafkaOutputOperatorTest, pull them up to a base class