Confluent Kafka：confluent-kafka-pythonクライアントでシリアル化とパーティショニングはどのように指定されていますか？

Question

1）Javaクライアントでは、producer.put（）を使用して、整数と文字列のシリアライザを追加できます。コンフルエントなkafka-pythonクライアントではどうすればいいですか？ 2）protoBufレコードをシリアル化するにはどうすればよいですか？質問＃1の

Answer 1

：質問＃2の

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) 

：下記のショーとして、設定にkey.serializerとvalue.serializerを追加し、独自のProtobufSerializerクラスとセットを実装{キー|値}それに.serializer。