[Bug] use kafka plugin, the consumer can not recive message

[katelei6]

Search before asking

• I had searched in the issues and found no similar issues.

Apache SkyWalking Component

Python Agent (apache/skywalking-python)

What happened

when i use skywalking the plugin of kafka, the consumer can not recive messae, I debug the code, find
#for item in carrier:
#headers.append((item.key, bytes(item.val, encoding='utf-8')))

if i not use this ,it can run well.

What you expected to happen

I think the plugin can not let the consumer happen issue.

How to reproduce

1 use skywalking of kafka
2 the consumer can not work well
3 when i not use the code of kafka plugin

4 the consumer is ok

I think the encode of header has issue.

Anything else

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[wu-sheng]

Maybe you are not using UTF-8? Header injection is important, and UTF-8 is the default charset in the whole SkyWalking ecosystem.

[wu-sheng]

No update.