public void handleDmaapMsg(String msg) {
this.createTask(msg) //
.subscribe(message -> logger.debug("handleDmaapMsg: {}", message), //
public void handleDmaapMsg(String msg) {
this.createTask(msg) //
.subscribe(message -> logger.debug("handleDmaapMsg: {}", message), //