PulsarMessageProducer.py is missing ping-pong logic to avoid timeouts