Confluent Kafka：如何在confluent-kafka-python客戶端中指定序列化和分區？

Question

1）在Java Client中，使用producer.put（）我們可以爲整數和字符串添加序列化程序。我們如何爲confluent-kafka-python客戶端做到這一點？ 2）我們如何序列化protoBuf記錄？

Answer 1

對於問題＃1：添加key.serializer和value.serializer在配置，如下顯示：

from confluent_kafka import Producer 
import socket 
conf = {'bootstrap.servers': "host1:9092,host2:9092", 
    'client.id': socket.gethostname(), 
    'key.serializer': 'key serializer classpath', 
    'value.serializer': 'value serializer classpath', 
    'default.topic.config': {'acks': 'all'}} 
producer = Producer(conf) 

對於問題2：實現自己的ProtobufSerializer類和集合{鍵|值} .serializer它。