Confluent Kafka : confluent-kafka-python 클라이언트에서 serialization 및 partition을 어떻게 지정합니까?

Question

1) Java 클라이언트에서 producer.put()을 사용하여 Integer 및 String에 대한 serializer를 추가 할 수 있습니다. 합류 - 카프카 - 파이썬 클라이언트의 경우 어떻게해야합니까? 2) protoBuf 레코드를 어떻게 serialize합니까? 질문 # 1

Answer 1

: 아래 표와 같이 설정에 key.serializer 및 value.serializer 추가 : 질문 # 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) 

: 자신의 ProtobufSerializer 클래스와 설정 구현 | 그것 .serializer {키 값을}.