예니의 코딩일기

실습 랜덤하게 사람 정보 생성 및 저장하는 KafkaProducer 구현 Faker 모듈 사용 pydantic 모듈의 BaseModel 사용 Topic 생성 후 추가 pip install faker pip install pydantic # person.py from pydantic import BaseModel class Person(BaseModel): id: str name: str title: str # fake_person_producer.py import uuid import json from typing import List from person import Person from faker import Faker from kafka.admin import NewTopic from kafka.e..

강의 Kafka 프로그래밍 언어 Java Apache Kafka Java Client Spring Kafka Python Confluent Kafka Python Kafka-Python pip install kafka-python .NET Confluent Kafka .NET Go Sarama Node.js node-rdkafka kafka-node Kafka 기본 프로그래밍 Producer 생성 from time import sleep from json import dumps from kafka import KafkaProducer producer = KafkaProducer( bootstrap_servers=['localhost:9092'], value_serializer=lambda x: dumps..