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类，并将{key|value}.serializer设置为它。