티스토리 뷰

공부

[Python] Kafka Serializer

승가비 2022. 5. 14. 20:51
728x90
>>> # Serialize string keys
>>> producer = KafkaProducer(key_serializer=str.encode)
>>> producer.send('flipflap', key='ping', value=b'1234')
>>> # Serialize json messages
>>> import json
>>> producer = KafkaProducer(value_serializer=lambda v: json.dumps(v).encode('utf-8'))
>>> producer.send('fizzbuzz', {'foo': 'bar'})

https://kafka-python.readthedocs.io/en/master/index.html?highlight=key_serializer#kafkaproducer 

 

kafka-python — kafka-python 2.0.2-dev documentation

Python client for the Apache Kafka distributed stream processing system. kafka-python is designed to function much like the official java client, with a sprinkling of pythonic interfaces (e.g., consumer iterators). kafka-python is best used with newer brok

kafka-python.readthedocs.io

 

728x90
저작자표시 비영리 (새창열림)

'공부' 카테고리의 다른 글

[Avro] schema (multiple record, null default of record) & convertor  (0) 2022.05.14
[Docker] naming rule: `docker/asdf.Dockerfile`  (0) 2022.05.14
[Slack] send message  (0) 2022.05.14
[Slack] https://slack.com/api/users.lookupByEmail  (0) 2022.05.08
[gradle] from maven `implementation(project(":data-core"))`  (0) 2022.05.08
댓글