我想通过转换接口来处理一个kafka流。:118) ~[spring-cloud-stream-binder-kafka-streams-3.0.8.RELEASE.jar:3.0.8.RELEASE]
at org.springframework.cloud.stream.binder.kafka.streams.KStreamBinder.doBindProducer$SingleWaiter.await(KafkaFutureImpl.java:108) ~[kafka-clients-2.3.1.jar:n
Kafka服务器在我的本地计算机上,我的spark服务器在aws上,我正在尝试连接这两个服务器。我收到错误"Failed to find data source: kafka“。亚马逊网络服务上的-Spark服务器kafka_df = spark.readStream \ .option("kafka.bootstrap.s