This is the central repository for all materials related to Kafka Streams : Real-time Stream Processing! Book by Prashant Pandey.

Gradle plugin to interact with Confluent Schema-Registry.

This is the central repository for all the materials related to Apache Kafka For Absolute Beginners Course by Prashant Pandey.

Clojure examples for Kafka and Kafka Streams (JAVA Interop)

An Avro Library that emphasizes testability and ease of use.

A platform to test solutions for using Kafka with Graphql

Implicitly converts typeclass encoders to kafka Serializer, Deserializer, Serde.

A client UI to inspect Kafka topics, consume, produce and much more.

Event Sourcing(CQRS) and Materialized views with Kafka Streams

Decrypting dexscreener avro data

An Avro SerDe implementation that integrates with the confluent schema registry and serializes and deserializes data according to the defined confluent wire format

The sample code the book "Kafka: The Definitive Guide (Gwen Shapira, Neha Narkhede, and Todd Palino)" and the personal study note of Apache Kafka.

No description provided.

Examples of Apache Flink® v2.1 applications showcasing the DataStream API, Table API in Java and Python, and Flink SQL, featuring AWS, GitHub, Terraform, Streamlit, and Apache Iceberg.

Firehose - Spark streaming 2.2 + Kafka 0.8_2

Distributed Transactions in Microservices with Kafka Streams and Spring Boot

Example of entities and Avro classes to be sent and persisted in Kafka

Streamline Avro schema registration and compatibility checks in Kafka with the avroschema-wizard-plugin, simplifying testing and integration with ease!

FIX-to-Avro converter, supporting custom FIX schemas and enabling the generation of both Avro data and its corresponding schema.

Kafka Avro Serde for Clojure

Examples using Kafka with C and C++

An example about online merchant monitor based on Kafka, Kafka Stream, Kafka Connect,KSQL

No description provided.

Kafka Serialization Playground

This repository contains sample Spring Boot setup for handling multiple event types in single Kafka topic.

A basic application to explain the use of Functional Kafka Streams with Scala using fs2-kafka library.

JKafkacat, a simple tool (inspired by kafkacat) to produce/consume messages from Apache Kafka

Example to demonstrate spring kafka avro producer and consumer and maintaining different versions of avro schema

Kaka Experimental with Apache Avro

Creates an Avro Schema from a bunch of JSON examples sent in