"Symfony Kafka consumer" lost connection with DB