پس از ساخت و پیکربندی فایل docker-compose.yml، میتوان Kafka و Zookeeper را اجرا کرد و وضعیت آنها را با استفاده از CLI بررسی نمود. CLI ابزارهای خط فرمان Kafka امکان مدیریت Topicها، پیامها و Consumerها را فراهم میکنند.
۱. اجرای Kafka با Docker Compose
برای اجرای سرویسها کافیست دستور زیر را در مسیر فایل docker-compose.yml اجرا کنید:
docker-compose up -d
گزینه -d
باعث میشود سرویسها در پسزمینه اجرا شوند.
۲. بررسی وضعیت کانتینرها
با دستور زیر میتوان وضعیت کانتینرهای Docker را مشاهده کرد:
docker ps
این دستور نشان میدهد که کانتینرهای Kafka و Zookeeper در حال اجرا هستند و پورتها به درستی نگاشت شدهاند.
۳. بررسی وضعیت Topicها و پیامها با CLI Kafka
Kafka ابزارهای CLI مختلفی دارد که با استفاده از آنها میتوان Topicها را مدیریت کرد:
لیست Topicها:
docker exec -it kafka kafka-topics --bootstrap-server localhost:9092 --list
ایجاد یک Topic جدید:
docker exec -it kafka kafka-topics --bootstrap-server localhost:9092 --create --topic my-topic --partitions 1 --replication-factor 1
نمایش جزئیات Topic:
docker exec -it kafka kafka-topics --bootstrap-server localhost:9092 --describe --topic my-topic
با استفاده از این دستورات میتوان اطمینان حاصل کرد که Kafka به درستی اجرا شده و Topicها و پیامها قابل مدیریت هستند.