It might be due transactional producer, transactions failed to commit will result in such behavior. Ref https://www.confluent.io/blog/transactions-apache-kafka/