daniel-shuy / kafka-protobuf-serde
Serializer/Deserializer for Kafka to serialize/deserialize Protocol Buffers messages
☆62Updated last week
Alternatives and similar repositories for kafka-protobuf-serde:
Users that are interested in kafka-protobuf-serde are comparing it to the libraries listed below
- Akka TCP and WebSocket transports for RSocket☆28Updated 5 years ago
- Utility project for working with Kafka Connect.☆34Updated 7 months ago
- Library for generating avro schema files (.avsc) based on DB tables structure☆50Updated 3 months ago
- Common utilities for Apache Kafka☆36Updated last year
- li-apache-kafka-clients is a wrapper library for the Apache Kafka vanilla clients. It provides additional features such as large message …☆133Updated last year
- A library for strong, schema based conversion between 'natural' JSON documents and Avro☆18Updated last year
- Lab project to showcase Flink's performance differences between using a SQL query and implementing the same logic via the DataStream API☆14Updated 4 years ago
- JUnit rule for spinning up a Kafka broker☆104Updated 3 months ago
- Protobuf compatible code generator☆29Updated last year
- Netifi Java Client☆25Updated 5 years ago
- Protocol Buffers protobuf compiler - multi-platform executable protoc JAR and API☆137Updated 7 months ago
- BlobIt - a Distributed Large Object Storage☆36Updated last year
- Flink Controller implements a Kubernetes Custom Controller (aka Kubernetes Operator) for Apache Flink☆53Updated 2 months ago
- A reactive driver for Aeron transport (https://github.com/real-logic/aeron)☆47Updated last month
- SQL for Kafka Connectors☆98Updated last year
- The ScaleOut Time Windowing Library for Java provides a set of windowing functions for time-ordered lists of events.☆21Updated 6 years ago
- Demo quering counts of a event stream with Apache Flink☆23Updated 6 years ago
- Dropwizard bundle and reporter for Prometheus☆26Updated last month
- Collection of utilities to allow writing java code that operates across a wide range of avro versions.☆77Updated this week
- Apache Pulsar Adapters☆24Updated 2 months ago
- ☆64Updated 5 years ago
- An example of building kubernetes operator (Flink) using Abstract operator's framework☆26Updated 5 years ago
- A scala extension for Project Reactor's Flux and Mono☆52Updated 3 years ago
- Integration between Micronaut and Pulsar☆18Updated this week
- A user friendly API for checking for and reporting on Avro schema incompatibilities.☆59Updated last year
- Kafka Interceptor for Zipkin☆35Updated 2 years ago
- LinkedIn's version of Apache Calcite☆22Updated 4 months ago
- Register built-in Kafka client metrics to Dropwizard Metrics☆36Updated last year
- Protobuf converter plugin for Kafka Connect☆94Updated last year
- Web Based Kafka Consumer and Producer☆69Updated 5 years ago