Registry / messaging / spark-streaming-kafka-0-10-2-11

spark-streaming-kafka-0-10-2-11

library2.4.8javamavenunverified

Apache Spark Streaming integration with Apache Kafka 0.10 for Scala 2.11.

<dependency>
  <groupId>org.apache.spark</groupId>
  <artifactId>spark-streaming-kafka-0-10_2.11</artifactId>
  <version>2.4.8</version>
</dependency>

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · SPARK-STREAMING-KA

spark-streaming-kafka-0-10-2-11

messagingjavav2.4.8

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

KafkaUtils

✓ org.apache.spark.streaming.kafka010.KafkaUtils

Creates a direct Kafka stream in Spark Streaming.

import org.apache.spark.streaming.kafka010.KafkaUtils; import org.apache.spark.streaming.api.java.JavaStreamingContext; public class KafkaStream { public static void main(String[] args) { JavaStreamingContext jssc = new JavaStreamingContext("local", "app", new Duration(1000)); // KafkaUtils.createDirectStream(...) } }

Debug

Known issues

breakingThis version is for Scala 2.11 and Kafka 0.10; newer Spark versions use different artifacts.

fix

Use the appropriate artifact for your Scala and Kafka versions.

affects: <=2.4.8

Upgrade

Version history

2.4.8latest on Maven

Audit

Dependencies

No dependency data recorded yet.

Agent activity

15 hits · last 30 days

node

OpenAI (training)

Resources

githubhttps://github.com/apache/spark ↗

homepagehttp://spark.apache.org/ ↗

docshttps://appdoc.app/artifact/org.apache.spark/spark-streaming-kafka-0-10_2.11/ ↗