Thanks for the answer and it worked like 95% success
I am facing a slight issue
when integration test is running, only 1st topic is shown which is healthchecks-topic but not 2nd topic dnd-pit-dev-act-outage-topic
it is taking some more time to show 2nd topic which eventually is failing test
any way can we ask kafka to wait until expected topic is shown ?