confluent-kafka python库不适用于ubutu14和python3

问题描述

我正在使用“ confluent-kafka == 1.0.1”。当我使用py3和ubuntu18时，它工作正常，但使用py3和ubuntu14时失败。我收到以下错误。

Traceback (most recent call last):
File "/usr/local/lib/python3.4/dist-packages/metrics_agent/kafka_writer.py",line 147,in enqueue_for_topic
producer.produce(topic_name,msg,partition=_get_partition(producer,topic_name))
File "/usr/local/lib/python3.4/dist-packages/confluent_kafka/serializing_producer.py",line 168,in produce
raise KeySerializationError(se)
confluent_kafka.error.KeySerializationError: 
KafkaError{code=_KEY_SERIALIZATION,val=-162,str="'bytes' object has no attribute 'encode'"}
Exception KafkaError{code=_KEY_SERIALIZATION,str="'bytes' object has no attribute 
'encode'"}
Traceback (most recent call last):
File "/usr/local/lib/python3.4/dist-packages/confluent_kafka/serializing_producer.py",line 166,in produce
key = self._key_serializer(key,ctx)
File "/usr/local/lib/python3.4/dist-packages/confluent_kafka/serialization/__init__.py",line 369,in __call__
return obj.encode(self.codec)
 AttributeError: 'bytes' object has no attribute 'encode'

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）