در پایتون می‌توان با استفاده از کتابخانه kafka-python یک Producer ساده برای ارسال پیام به یک Topic در Kafka نوشت. در ادامه نمونه کد ساده ارائه شده است.
نمونه کد Producer ساده:
from kafka import KafkaProducer
# ساخت Producer و اتصال به Broker
producer = KafkaProducer(
bootstrap_servers='localhost:9092',
value_serializer=lambda v: v.encode('utf-8') # تبدیل پیام به بایت
)
# ارسال پیام‌ها به Topic
topic_name = 'my-topic'
producer.send(topic_name, value='سلام Kafka')
producer.send(topic_name, value='پیام دوم')
# اطمینان از ارسال تمام پیام‌ها
producer.flush()
print("پیام‌ها با موفقیت ارسال شدند.")
توضیح کد:
- KafkaProducer: کلاس اصلی برای ایجاد Producer و اتصال به Broker.
- bootstrap_servers: آدرس و پورت Broker که Producer به آن متصل می‌شود.
- value_serializer: مشخص می‌کند که پیام‌ها چگونه سریالایز شوند (در اینجا به بایت تبدیل می‌شوند).
- send: ارسال پیام به Topic مشخص.
- flush: اطمینان از ارسال تمام پیام‌ها قبل از پایان برنامه.