classpass / flink-kotlin
Kotlin helpers to make writing Flink jobs with Kotlin 27% more delightful
☆33Updated last month
Alternatives and similar repositories for flink-kotlin:
Users that are interested in flink-kotlin are comparing it to the libraries listed below
- Kotlin support for Apache Flink☆18Updated 3 weeks ago
- ☆36Updated 2 years ago
- showcases Grafana dashboards for Kafka Stream applications leveraging client JMX metrics.☆39Updated 3 weeks ago
- Gradle plugin to interact with Confluent Schema-Registry.☆112Updated last month
- Aiven's collection of Single Message Transformations (SMTs) for Apache Kafka Connect☆75Updated 2 weeks ago
- Collection of utilities to allow writing java code that operates across a wide range of avro versions.☆77Updated last month
- A Kafka Serializer and SerDe implementation based on Avro4k serializers☆21Updated 5 months ago
- Serializer/Deserializer for Kafka to serialize/deserialize Protocol Buffers messages☆62Updated last month
- An avro converter for Kafka Connect without a Schema Registry☆53Updated 4 years ago
- Quarkus Extension to support Scala 3☆57Updated last week
- Apache Pekko Sample Projects☆47Updated last week
- ☆17Updated 2 years ago
- Fast Apache Avro serialization/deserialization library☆43Updated 4 years ago
- Restate SDK for JVM Languages☆26Updated this week
- A library that provides in-memory instances of both Kafka and Confluent Schema Registry to run your tests against.☆114Updated 3 weeks ago
- The Internals of Apache Kafka☆51Updated last year
- A user friendly API for checking for and reporting on Avro schema incompatibilities.☆59Updated 10 months ago
- ☆18Updated 2 years ago
- Proteus Java Client☆42Updated 5 years ago
- Akka TCP and WebSocket transports for RSocket☆28Updated 5 years ago
- Utility project for working with Kafka Connect.☆33Updated 5 months ago
- Testcontainers for the Confluent Platform Components☆51Updated this week
- A Kafka Serde that reads and writes records from and to Blob storage (S3, Azure, Google) transparently.☆57Updated this week
- Persistent Stateful Actor System☆33Updated this week
- Avro Schema Evolution made easy☆34Updated 11 months ago
- Kubernetes Operator for the Ververica Platform☆35Updated 2 years ago
- BigQuery integration to Apache Flink's Table API☆28Updated this week
- JUnit rule for spinning up a Kafka broker☆104Updated last month