Change code to use dmaap microservice