Run with ./gradlew run --args="<bootstrap servers>" Uses the topics "input-topic" and "output-topic" which is assumed to exist.