Confluence Kafka: Wie wird die Serialisierung und Partitionierung im konfluent-kafka-python-Client festgelegt?

Question

1) Im Java-Client können wir mit producer.put() Serializer für Integer und Strings hinzufügen. Wie machen wir das für einen konfluenten Kafka-Python-Client? 2) Wie können wir ProtoBuf-Datensätze serialisieren?

Answer 1

Zu Frage # 1: Fügen Sie key.serializer und value.serializer in der Config, wie unten gezeigt:

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) 

Zu Frage # 2: Implementieren Sie Ihre eigene ProtobufSerializer Klasse und setzen {key | Wert} .serializer zu.