In PulsarKafkaProducer use flush() from pulsar API (#3549)

1 file changed