我正在尝试将Spark Dataframe流式传输到Kafka使用者。我做不到,请您告诉我。
我可以将数据从Kafka生产者选择到Spark,并且已经执行了一些操作。在处理完数据之后,我有兴趣将其流回Kafka(消费者)。
apache-kafka apache-spark
apache-kafka ×1
apache-spark ×1