diff --git a/notes/Spark_Streaming整合Kafka.md b/notes/Spark_Streaming整合Kafka.md index 975a8d9..0244587 100644 --- a/notes/Spark_Streaming整合Kafka.md +++ b/notes/Spark_Streaming整合Kafka.md @@ -26,7 +26,7 @@ Spark针对Kafka的不同版本,提供了两套整合方案:`spark-streaming | Direct DStream | Yes | Yes | | SSL / TLS Support | No | Yes | | Offset Commit API(偏移量提交) | No | Yes | -| Dynamic Topic Subscription(动态主题订阅) | No | Yes | +| Dynamic Topic Subscription
(动态主题订阅) | No | Yes | 本文使用的Kafka版本为`kafka_2.12-2.2.0`,故采用第二种方式进行整合。 @@ -48,7 +48,8 @@ Spark针对Kafka的不同版本,提供了两套整合方案:`spark-streaming spark-streaming-kafka-0-10_${scala.version} 2.4.3 - + com.thoughtworks.paranamer paranamer @@ -320,4 +321,4 @@ bin/kafka-console-producer.sh --broker-list hadoop001:9092 --topic spark-streami ## 参考资料 -1. https://spark.apache.org/docs/latest/streaming-kafka-0-10-integration.html \ No newline at end of file +1. https://spark.apache.org/docs/latest/streaming-kafka-0-10-integration.html