پس از راه‌اندازی Kafka، یکی از اولین کارهایی که توسعه‌دهندگان انجام می‌دهند، ایجاد یک Topic و ارسال و دریافت پیام نمونه است. این کار به درک بهتر جریان داده‌ها و مفاهیم Producer و Consumer کمک می‌کند.
۱. ایجاد یک Topic جدید
برای ایجاد Topic جدید به نام my-topic با یک Partition و یک Replication Factor از دستور زیر استفاده کنید:
docker exec -it kafka kafka-topics --bootstrap-server localhost:9092 --create --topic my-topic --partitions 1 --replication-factor 1
۲. ارسال پیام نمونه با Producer
برای ارسال پیام نمونه به Topic، می‌توان از ابزار خط فرمان Producer استفاده کرد:
docker exec -it kafka kafka-console-producer --bootstrap-server localhost:9092 --topic my-topic
>سلام Kafka
>پیام دوم
هر خطی که وارد می‌کنید، به عنوان یک پیام جداگانه در Topic ارسال می‌شود.
۳. دریافت پیام با Consumer
برای مشاهده پیام‌های موجود در Topic، می‌توان از ابزار خط فرمان Consumer استفاده کرد:
docker exec -it kafka kafka-console-consumer --bootstrap-server localhost:9092 --topic my-topic --from-beginning
گزینه --from-beginning باعث می‌شود که تمام پیام‌های موجود در Topic از ابتدا نمایش داده شوند.
توضیح فرآیند:
- Producer پیام‌ها را به Topic می‌فرستد.
- Broker پیام‌ها را در Partition ذخیره می‌کند.
- Consumer پیام‌ها را می‌خواند و می‌تواند پردازش یا ذخیره‌سازی کند.