avro-kafka

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.

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.

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

Firehose - Spark streaming 2.2 + Kafka 0.8_2

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!

The project demonstrates how an order workflow can span multiple independently deployed services while maintaining business consistency through event-driven communication, local transactions and compensating actions instead of relying on a traditional distributed database transaction.

Kafka Avro Serde for Clojure