test(kafka): fix flaky consumer ignore-topic tests with producer.flush()

test(kafka): fix flaky consumer ignore-topic tests with producer.flush() #1956