Fluent Kafka Streams Test with Java

A Kafka Serde that reads and writes records from and to Blob storage (S3, Azure, Google) transparently.

A library for error handling in Kafka Streams.

Utilities for working with Kafka

Utility functions and base classes for Kafka Streams applications

Collection of reusable workflows and composite actions for Github

A Kafka Streams application that analyzes dead letters in your Kafka cluster

A Java client for KServe inference services

Deploy Kafka pipelines to Kubernetes

Validate JWTs via JWKS