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

Question

1) 在 Java 客户端中，使用 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 类并将 {key|value}.serializer 设置为它。