We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Python Agent (apache/skywalking-python)
SkyWalking agent failed to start if using kafka protocol with sasl_mechanism=PLAIN.
SkyWalking agent starts successfully when using kafka protocol with sasl_mechanism=PLAIN.
run a gunicorn app with a command like
SW_AGENT_PROTOCOL=kafka \ SW_KAFKA_BOOTSTRAP_SERVERS=localhost:9092 \ SW_KAFKA_REPORTER_CONFIG_security_protocol=SASL_PLAINTEXT \ SW_KAFKA_REPORTER_CONFIG_sasl_mechanism=PLAIN \ SW_KAFKA_REPORTER_CONFIG_sasl_plain_username=************ \ SW_KAFKA_REPORTER_CONFIG_sasl_plain_password=************ \ SW_AGENT_NAME=demo::gunicorn \ sw-python -d run -p gunicorn main:app
The agent failed to start with AttributeError: 'SkyWalkingAgent' object has no attribute '_SkyWalkingAgent__log_queue'
Using kafka protocol with sasl_mechanism=PLAIN leads to "log.warning('%s: Sending username and password in the clear', self)". https://github.com/dpkp/kafka-python/blob/a6d0579d3cadd3826dd364b01bc12a2173139abc/kafka/conn.py#L624
the logging module was replaced by sw_logging, but __log_queue was not initialized yet
The text was updated successfully, but these errors were encountered:
Please send a pull request when you are ready.
Sorry, something went wrong.
tsonglew
No branches or pull requests
Search before asking
Apache SkyWalking Component
Python Agent (apache/skywalking-python)
What happened
SkyWalking agent failed to start if using kafka protocol with sasl_mechanism=PLAIN.
What you expected to happen
SkyWalking agent starts successfully when using kafka protocol with sasl_mechanism=PLAIN.
How to reproduce
run a gunicorn app with a command like
Anything else
The agent failed to start with AttributeError: 'SkyWalkingAgent' object has no attribute '_SkyWalkingAgent__log_queue'
Using kafka protocol with sasl_mechanism=PLAIN leads to "log.warning('%s: Sending username and password in the clear', self)".
https://github.com/dpkp/kafka-python/blob/a6d0579d3cadd3826dd364b01bc12a2173139abc/kafka/conn.py#L624
the logging module was replaced by sw_logging, but __log_queue was not initialized yet
Are you willing to submit a pull request to fix on your own?
Code of Conduct
The text was updated successfully, but these errors were encountered: