superLincoln

We have the same issue in producer side, with set producer connected when get a producer instance from kafka client in "kafkajs": "^1.15.0"., there is data loss each time restart...

It is probably because you submit message without connection built at the beginning , it happened in parallel coding but no problem in serial coding. So just make sure there...