Code examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streaming 1.1+, while using Apache Avro as the data serialization format.

Benchmark comparing various data serialization libraries (thrift, protobuf etc.) for C++

Examples for codefoundry.dev

Apache Avro <-> pandas DataFrame

Generate Avro Schemas from a Python class. Serialize and Deserialize python instances with avro schemas

Count records in Avro files efficiently

Clean up attribute names for Apache NiFi to send to Apache Avro

A pure python avro schema validator

Kafka consumer application which reads messages from Kafka and based on the schema registered in a schema registry and enriches the data. This is just a prototype on how we can efficiently evolve a schema and read messages with BACKWARD compatibility with out breaking the consumers. This application can be used as a base for a stateless stream processing application which would involve processing one event at a time or filtering though a stream of events.

Kafka producer application which publishes messages to Kafka and registers the schema of the message in a schema registry

Customer Relationship Management use case for InfluxData Webinar - 16/06/2020

Sample project to try out Apache Avro.

Producer and consumer of traffic data for Apache Kafka

Este es un breve ejercicio para ejemplificar el uso de Apache Avro ™ utilizando Java.

Apache Kafka Producer and Consumer which uses Spark-Streaming and Avro Serialization written in Scala.

Samples and documents of data platform, e.g. sprak, embulk and airflow...

schema registry using kafka avro

A Java Program which uses Apache Avro to serialize and deserialize data from a .csv file.

Apache Kafka Producer and Consumer which uses Avro Serialization written in Java.

Simulate alert streams for the Fink broker

Avro File using Apache Spark and Scala

An Event Bus implementation using Apache Kafka and Apache Avro

An Eclipse editor plugin for defining Apache Avro IDL

Experiment with CNCF's remote procedure call framework i.e grpc, apache-thrift, apache-avro

Sending data to multiple location

Hotel Booking project