Apache KafkaApache Kafka

Producer → [Topic: orders (3 Partitions)] → Consumer Group
              Partition 0: msg1, msg3
              Partition 1: msg2, msg5
              Partition 2: msg4, msg6

from kafka import KafkaProducer, KafkaConsumer
import json

# 생산자
producer = KafkaProducer(
    bootstrap_servers=['localhost:9092'],
    value_serializer=lambda v: json.dumps(v).encode()
)
producer.send('orders', {'order_id': 123, 'amount': 50000})

# 소비자
consumer = KafkaConsumer(
    'orders',
    bootstrap_servers=['localhost:9092'],
    group_id='payment-service',
    value_deserializer=lambda v: json.loads(v)
)
for msg in consumer:
    print(msg.value)  # {'order_id': 123, 'amount': 50000}