brendonanderson

task startServer(type: SpawnProcessTask) {
    doFirst {
        kafkaEmbedded = new KafkaEmbedded(1, true, 1, 'output-topic')
        kafkaEmbedded.before()
        bootPort = availablePort()
        command "java -Dserver.port=${bootPort} -Dspring.kafka.producer.bootstrap-servers=${kafkaEmbedded.getBrokersAsString()} -Dspring.kafka.consumer.group-id=func-test -jar ${projectDir}/build/libs/emb-kafka-${version}.jar"
        ready 'Started EmbKafkaApplication' // looks for this text to indicate process has started
    }
}