If it is closed then I should see related close log, right? As you can see in the log above, the producer is not closed and is being consumed right after the creation. This happens one in a thousand or even less.
The producer may be closed because you called close() on it or because you closed its transport. In the former you’ll see a log and in the latter as well. Check close() and transportClosed() methods:
So, if the producer is closed it’s closed due to something. Maybe you called close on the worker or on the router, which will close the transport, which will call producer.transportClosed(). There are no more options. So maybe you are calling transport.consume() by passing a producerId of an already closed Producer.