Discover lensesio/lenses-udf-example Open Source project

A collection of open source Apache 2.0 Kafka Connector maintained by Lenses.io.

2,019

stream-reactor

Web Tool for Kafka Topics |

1,005

kafka-topics-ui

Web tool for Kafka Connect |

877

kafka-connect-ui

Web tool for Avro Schema Registry |

504

schema-registry-ui

kafka-cheat-sheet

lenses-docker

❤for real-time DataOps - where the application and data fabric blends - Lenses

154

kafka-connect-tools

Kafka Connect Tooling

A CLI and Go client for Kafka Schema Registry. This repository is deprecated and no longer maintained.

118

schema-registry

117

kafka-connect-query-language

SQL for Kafka Connectors

Environment, operations and runtime-meta testing tool.

coyote

cypress-websocket-testing

Test WebSocket connections with Cypress

TypeScript

tableprinter

Fast and easy-to-use table printer written in Go. Parse and print anywhere go values such as structs, slices, maps or any compatible value type as a table with ease.

kafka-helm-charts

In-deprecation. For Lenses please check lensesio/lenses-helm-charts. Soon Stream Reactor will also get its own Helm repository.

Smarty

secret-provider

Open Source Secret Provider plugin for the Kafka Connect framework

Lenses.io CLI (command-line interface)

lenses-go

kafka-autocomplete

Bash completion for Kafka command line utilities.

Kafka-Connect SMT (Single Message Transformations) with SQL syntax (Using Apache Calcite for the SQL parsing)

kafka-connect-kcql-smt

Test suite for Kafka Connect connectors based on Landoop's Coyote and docker.

kafka-connectors-tests

Dockerfile

fast-avro-write

Writing an Avro file is not as fast as you might want it. This is a library to write considerably faster to an avro file.

Use SQL to transform your avro schema/records

avro-sql

Repository for advanced unit-testing with embedded kafka services

kafka-testing

Create Kafka-Connect clusters with docker . You put the Kafka, we put the Connect.

fast-data-connect-cluster

json-sql

Common components used across the datamountaineer kafka connect connectors

kafka-connect-common

Lenses.io JDBC driver for Apache Kafka

lenses-jdbc

Kotlin

stream-reactor-dockers

Docker images for Stream Reactor

Python library for Lenses.io / Kafka platform engineers

lenses-python

Python

lenses-helm-charts

Helm Charts for Lenses.io

HTML

hadoop-bash-completion

Bash completion for hadoop. Includes commands, switches and directory/filename completion.

An example of streaming microservices with Apache Kafka and Data Flow Topology integration with Lenses Ⓡ DataOps Platform. You can see it in action here: https://www.youtube.com/watch?v=V15mrcA1Wxg

lenses-topology-example

A small project to allow publishing data to Apache Kafka, Apache Pulsar or any other target system

datagen

User interface for avro4s

landoop-avro4s-ui

HTML

redux-lenses-streaming-example

TestKit - Embedded Kafka, Zookeeper, Schema Registry

kafka-testkit

Public docker images we use for our infrastructure.

docker-images

ftp-kafka-converters

Blog on Kafka Connect [ FTP -> KAFKA ]

kafka-connect-transformers

A small tutorial on Avro, MQTT and Kafka using docker and go.

ais-avro-mqtt-connect-tutorial

lenses-jdbc-spark

Apache Spark with Kafka via JDBC !!!

kafka-avro-generator

lenses-ldap-plugin-template

Contains the documentation for the Kafka Execution Management System connector.

kafka-celonis-ems-connector

lenses-serde

Defines interface for pluggable lenses alert services integration, along with some officially supported implementations.

bite

The Cobra's bite

lenses-alerts-plugin

Avro <=> Scala through a web ui => http://landoop.com/labs

avro4s-ui

Sample roles from Landoop DevOps team.

ansible

Available templates to deploy Lenses in different cloud providers

lenses-cloud-templates

Python

avro-kcql

This is a dummy application that mocks the Kafka Connect API.

connect-mock

Kotlin

kafka-connect-smt

A Lenses.io Kafka Connect Single Message Transform(SMT) collection

kafka-ui-lib

lenses-serde-protobuf-example

Provides support for json projections using the sql like syntax of KCQL

json-kcql

sql-core

A sample project using the HTTP request to handle the authentication

lenses-security-http-sample