Skip to content
  • Home
  • About
  • Write For US
|       { One stop for all Spark Examples }
Spark by {Examples}
  • Spark
    • Spark RDD
    • Spark DataFrame
    • Spark SQL Functions
    • What’s New in Spark 3.0?
    • Spark Streaming
    • Apache Spark Interview Questions
  • PySpark
  • Hive
  • Pandas
  • NumPy
  • R
  • Interview Q
    • Spark Interview Questions
  • More
    • KafkaApache Kafka Tutorials with Examples
    • H2O.ai
    • Apache Hadoop
    • Apache HBase
    • Apache Cassandra
    • Snowflake Database
    • H2O Sparkling Water
    • Scala Language
Menu Close
  • Spark
    • Spark RDD
    • Spark DataFrame
    • Spark SQL Functions
    • What’s New in Spark 3.0?
    • Spark Streaming
    • Apache Spark Interview Questions
  • PySpark
  • Hive
  • Pandas
  • NumPy
  • R
  • Interview Q
    • Spark Interview Questions
  • More
    • Kafka
    • H2O.ai
    • Apache Hadoop
    • Apache HBase
    • Apache Cassandra
    • Snowflake Database
    • H2O Sparkling Water
    • Scala Language
  • Home
  • About
  • Write For US
Read more about the article Spark Streaming – Kafka messages in Avro format
Apache Kafka / Apache Spark / Apache Spark Streaming

Spark Streaming – Kafka messages in Avro format

This article describes Spark Structured Streaming from Kafka in Avro file format and usage of from_avro() and to_avro() SQL functions using the Scala programming language. Spark Streaming Kafka messages in…

7 Comments
March 23, 2019
Read more about the article Spark Streaming with Kafka Example
Apache Spark / Apache Spark Streaming

Spark Streaming with Kafka Example

Spark Streaming with Kafka Example Using Spark Streaming we can read from Kafka topic and write to Kafka topic in TEXT, CSV, AVRO and JSON formats, In this article, we…

1 Comment
March 17, 2019
Read more about the article Spark SQL Batch Processing – Produce and Consume Apache Kafka Topic
Apache Kafka / Apache Spark

Spark SQL Batch Processing – Produce and Consume Apache Kafka Topic

This article describes Spark Batch Processing using Kafka Data Source. Unlike Spark structure stream processing, we may need to process batch jobs which reads the data from Kafka and writes the data to Kafka topic in batch mode. To do this we should use read instead of resdStream similarly write instead of writeStream on DataFrame

1 Comment
March 11, 2019
Read more about the article Kafka consumer and producer example with a custom serializer
Apache Kafka / Scala

Kafka consumer and producer example with a custom serializer

Kafka allows us to create our own serializer and deserializer so that we can produce and consume different data types like Json, POJO e.t.c. In this post will see how to produce and consumer User pojo object. To stream pojo objects one need to create custom serializer and deserializer.

1 Comment
January 4, 2019
Read more about the article Apache Kafka Producer and Consumer in Scala
Apache Kafka

Apache Kafka Producer and Consumer in Scala

This article explains how to write Kafka Producer and Consumer example in Scala. Producer sends messages to Kafka topics in the form of records, a record is a key-value pair along with topic name and consumer receives a messages from a topic.

7 Comments
January 4, 2019

Categories

  • Apache Hadoop
  • Apache Spark
  • Apache Spark Streaming
  • Apache Kafka
  • Apache HBase
  • Apache Cassandra
  • Snowflake Database
  • H2O Sparkling Water
  • PySpark

Recent Posts

  • NumPy flip() Function in Python
  • PySpark Get Number of Rows and Columns
  • How to Convert NumPy Matrix to Array
  • How to Use NumPy stack() in Python
  • How to use NumPy vstack() in Python
  • PySpark count() – Different Methods Explained
  • Python NumPy hstack Function
  • PySpark NOT isin() or IS NOT IN Operator
  • PySpark isin() & SQL IN Operator
Privacy & Cookies: This site uses cookies. By continuing to use this website, you agree to their use.
To find out more, including how to control cookies, see here: Cookie Policy

About SparkByExamples.com

SparkByExamples.com is a Big Data and Spark examples community page, all examples are simple and easy to understand, and well tested in our development environment Read more ..
    Copyright sparkbyexamples.com