Displaying 1 to 19 from 19 results

kafka-rest - Confluent REST Proxy for Kafka

  •    Java

The Kafka REST Proxy provides a RESTful interface to a Kafka cluster, making it easy to produce and consume messages, view the state of the cluster, and perform administrative actions without using the native Kafka protocol or clients.

schema-registry - Schema registry for Kafka

  •    Java

Schema Registry provides a RESTful interface for storing and retrieving versioned Avro schemas for use with Kafka.

fast-data-dev - Kafka Docker for development

  •    Shell

Apache Kafka docker image for developers; with Landoop Lenses (landoop/kafka-lenses-dev) or Landoop's open source UI tools (landoop/fast-data-dev). Have a full fledged Kafka installation up and running in seconds and top it off with a modern streaming platform (only for kafka-lenses-dev), intuitive UIs and extra goodies. Also includes Kafka Connect, Schema Registry, Landoop Stream Reactor 25+ Connectors and more.

registry - Schema Registry

  •    Java

Registry is a versioned entity framework that allows to build various registry services such as Schema Registry, ML Model Registry etc..

avro_turf - A library that makes it easier to use the Avro serialization format from Ruby.

  •    Ruby

The AvroTurf::SchemaRegistry, AvroTurf::CachedSchemaRegistry, and FakeSchemaRegistryServer names have been deprecated because the Avro spec recently introduced an incompatible single-message encoding format. These classes have been renamed to AvroTurf::ConfluentSchemaRegistry, AvroTurf::CachedConfluentSchemaRegistry, and FakeConfluentSchemaRegistry.

puppet-confluent - Puppet Module for installing and configuring the Confluent Platform

  •    Puppet

This puppet module is used to install and configure the Confluent Platform. The documentation is available here. Puppet only allows version numbers in <major>.<minor>.<version> format. Due to this limitation the versioning schema matches the major and minor versions of the Confluent Platform. Meaning 3.2.1234 of the puppet module is for 3.2.x of the Confluent platform.

sbt-avro - Generate Scala classes from Apache Avro schemas hosted on a remote Confluent Schema Registry

  •    Scala

sbt-avro is a sbt 1.x plugin for generating Scala classes from Apache Avro schemas hosted on a remote Confluent Schema Registry. By default sbt-avro will download all Avro schema files from local schema registry to your default resources_managed directory (ie: target/scala-2.12/resources_managed/main/avro/). Please check settings section for more information about available settings.

schema-registry - A CLI and Go client for Kafka Schema Registry

  •    Go

This repository contains a Command Line Interface (CLI) and a Go client for the REST API of Confluent's Kafka Schema Registry. The schema registry url can be configured through the SCHEMA_REGISTRY_URL environment variable, and overridden through --url. When none is provided, http://localhost:8081 is used as default.

schema-registry-ui - Web tool for Avro Schema Registry |

  •    Javascript

This is a web tool for the confluentinc/schema-registry in order to create / view / search / evolve / view history & configure Avro schemas of your Kafka cluster. You will need schema-registry installed with CORS enabled.

confluent-spark-avro - Spark UDFs to deserialize Avro messages with schemas stored in Schema Registry

  •    Scala

Spark UDFs to deserialize Avro messages with schemas stored in Schema Registry. More details about Schema Registry on the official website. We expect that you use it together with native Spark Kafka Reader.

go-kafka-avro - A library provides consumer/producer to work with kafka, avro and schema registry

  •    Go

A library provides consumer/producer to work with kafka, avro and schema registry

cp-ansible - Ansible playbooks for the Confluent Platform

  •    Shell

You can find the documentation for running this playbook at https://docs.confluent.io/current/tutorials/cp-ansible/docs/index.html.

protein - Encoding/decoding library for Protobuf with schema-versioning and runtime-decoding capabilities

  •    Go

Protein is an encoding/decoding library for Protobuf that comes with schema-versioning and runtime-decoding capabilities. An upcoming blog post detailing the inner workings of these components is in the works and shall be available soon.

schemer - Schema registry for CSV, TSV, JSON, AVRO and Parquet schema

  •    Scala

Schema registry with support for CSV, TSV, AVRO, JSON and Parquet. Has ability to infer schema from a given data source. schemer-registry is a schema registry for storing the metadata about schema and schema versions. It provides a GraphQL API for adding, viewing and inferring schemas.

avro-schema-registry - Implementation of the Confluent Schema Registry API as a Rails application

  •    Ruby

A service for storing and retrieving versions of Avro schemas. Schema versions stored by the service are assigned an id. These ids can be embedded in messages published to Kafka avoiding the need to send the full schema with each message.

kafkacli - CLI and Go Clients to manage Kafka components (Kafka Connect & SchemaRegistry)

  •    Go

Apache Kafka is a high-throughput, distributed, publish-subscribe messaging system. Go Lang must be installed in order to build the project.

ccloud-tools - Running Tools from Confluent Platform along with your Confluent Cloud™ Cluster

  •    HCL

This is an unofficial open-source project created to aid in quickly provisioning Confluent Platform Tools (i.e.: REST Proxy, Kafka Connect, KSQL, Control Center) to be used while developing applications with Confluent Cloud. The provisioning process may take about ~5 minutes. Once it is finished, the tools will be available to use right way via the publicly exposed load balancers. The diagram below shows how this works.