时间戳

首页 > 解决方案 > confluent-kafka python 库不适用于 ubutu14 和 python3

apache-kafka - 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,val=-162,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'

标签： apache-kafkaconfluent-platformconfluent-kafka-python

解决方案

推荐阅读