dengshaochun commented on issue #150:
URL:
https://github.com/apache/pulsar-client-python/issues/150#issuecomment-1697043714
It cannot be fully reproduced, but the online environment has always been
problematic. The test of a separate celery + pulsar code is normal. At present,
there is no idea. The online environment reports the following errors:
```text
p._producer = self._client.create_producer(topic, conf)
_pulsar.TopicNotFound: Pulsar error: TopicNotFound
0000-00-00 00:00:00.000 WARN [0000-00-00 00:00:00.000 ERROR [0000-00-00
00:00:00.000 WARN [0000-00-00 00:00:00.000 ERROR [0000-00-00 00:00:00.000 WARN
[0000-00-00 00:00:00.000 ERROR [0000-00-00 00:00:00.000 INFO [0000-00-00
00:00:00.000 ERROR [0000-00-00 00:00:00.000 INFO [0000-00-00 00:00:00.000 INFO
[0000-00-00 00:00:00.000 INFO [0000-00-00 00:00:00.000 INFO [0000-00-00
00:00:00.000 INFO [0000-00-00 00:00:00.000 INFO [0000-00-00 00:00:00.000 INFO
[0000-00-00 00:00:00.000 INFO [0000-00-00 00:00:00.000 INFO [0000-00-00
00:00:00.000 INFO [0000-00-00 00:00:00.000 INFO [0000-00-00 00:00:00.000 INFO
[0000-00-00 00:00:00.000 INFO [
```
The online environment only has problems when calling celery.delay, and
there will be no exception when calling the function directly，as follows
```python
# ok
mock_data2pulsar(cnt=1000)
# exception
mock_data2pulsar.delay(cnt=1000)
```
debug `pulsar/__init__.py` print `topic` and `conf` before `p._producer =
self._client.create_producer(topic, conf)` looks ok
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
