برای اتصال، باید کانکتور Kafka را در SparkSession فعال کنید. سپس دادهها را از topicهای Kafka بخوانید و با DataFrameها تحلیل کنید. پارامترهای bootstrap.servers و subscribe برای تنظیم اتصال ضروریاند. پس از تحلیل، خروجی را میتوانید در پایگاه داده یا داشبورد نمایش دهید.
برای مشاهدهٔ ادامه، خرید کنید
دسترسی سریع و فوری