diff --git a/kafka-consumer-direct/build.gradle b/kafka-consumer-direct/build.gradle index 28235b7..6075b6b 100644 --- a/kafka-consumer-direct/build.gradle +++ b/kafka-consumer-direct/build.gradle @@ -31,7 +31,7 @@ dependencies { implementation group: 'org.apache.kafka', name: 'kafka_2.12', version: '3.5.0' implementation group: 'com.google.common', name: 'google-collect', version: '1.0' implementation group: 'org.apache.spark', name: 'spark-core_2.12', version: '3.4.0' - implementation group: 'org.apache.spark', name: 'spark-streaming_2.12', version: '3.3.2' + implementation group: 'org.apache.spark', name: 'spark-streaming_2.12', version: '3.5.0' implementation group: 'org.apache.spark', name: 'spark-sql_2.12', version: '3.4.0' implementation group: 'org.apache.beam', name: 'beam-sdks-java-extensions-json-jackson', version: '2.48.0' implementation project(':transformations') diff --git a/kafka-consumer-spark/build.gradle b/kafka-consumer-spark/build.gradle index eb9a08f..57938d5 100644 --- a/kafka-consumer-spark/build.gradle +++ b/kafka-consumer-spark/build.gradle @@ -30,7 +30,7 @@ dependencies { implementation group: 'org.apache.kafka', name: 'kafka_2.12', version: '3.5.0' implementation group: 'com.google.common', name: 'google-collect', version: '1.0' implementation group: 'org.apache.spark', name: 'spark-core_2.12', version: '3.4.0' - implementation group: 'org.apache.spark', name: 'spark-streaming_2.12', version: '3.3.2' + implementation group: 'org.apache.spark', name: 'spark-streaming_2.12', version: '3.5.0' implementation group: 'org.apache.spark', name: 'spark-sql_2.12', version: '3.4.0' implementation project(':transformations') }