1） 在java客户机中，使用producer.put（）可以为整数和字符串添加序列化程序。对于合流kafka python客户端，我们如何做到这一点？2） 我们如何序列化protobuf记录？
ia2d9nvy1#
对于问题1：添加 key.serializer 以及 value.serializer 在配置中，如下所示：
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设置为它。
1条答案
按热度按时间ia2d9nvy1#
对于问题1：添加
key.serializer以及value.serializer在配置中，如下所示：对于问题2：实现自己的protobufserializer类并将{key | value}.serializer设置为它。