#

kafka-connect

Here are 382 public repositories matching this topic...

debezium / debezium

Star

Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.

database kafka kafka-connect apache-kafka kafka-producer cdc change-data-capture debezium event-streaming

Updated Dec 24, 2020
Java

confluentinc / ksql

Star

Open

Add NULLIF function

1

rmoff commented Nov 3, 2020

It would be useful if ksqlDB had a NULLIF function, as common across SQL in other platforms.

Example from postgres:

NULLIF(value1, value2)
The NULLIF function returns NULL if and only if value1 and value2 are equal. Otherwise it returns value1.

Read more

enhancement good first issue user-defined-functions

Open

KSQLDB fails to start if ssl.keystore.type=pkcs12 instead of ssl.keystore.type=PKCS12

Open

Support HEX Literals

Find more good first issues →

strimzi-kafka-operator

strimzi / strimzi-kafka-operator

Star

Apache Kafka running on Kubernetes

docker kubernetes kafka openshift messaging data-stream kafka-connect kubernetes-operator kafka-streams kubernetes-controller data-streaming enmasse data-streams

Updated Dec 26, 2020
Java

confluentinc / cp-docker-images

Star

[DEPRECATED] Docker images for Confluent Platform.

kafka confluent kafka-connect docker-images kafka-streams

Updated Dec 18, 2020
Python

xaecbd / KafkaCenter

Star

KafkaCenter is a unified platform for Kafka cluster management and maintenance, producer / consumer monitoring, and use of ecological components.

kafka kafka-connect kafka-manager kafka-monitor kafka-eagle ksql connect-ui kafkacenter kafkamanager kafka-center kmanager kafkaoffsetmonitor kafka-connect-ui

Updated Sep 26, 2020
Java

lensesio / stream-reactor

Star

Streaming reference architecture for ETL with Kafka and Kafka-Connect. You can find more on http://lenses.io on how we provide a unified solution to manage your connectors, most advanced SQL engine for Kafka and Kafka Streams, cluster monitoring and alerting, and more.

Updated Dec 20, 2020
Scala

demo-scene

confluentinc / demo-scene

Star

Scripts and samples to support Confluent Platform talks. May be rough around the edges. For automated tutorials and QA'd code, see https://github.com/confluentinc/examples/

mysql elasticsearch kafka syslog kafka-connect kafka-streams debezium ksql

Updated Dec 18, 2020
Shell

confluentinc / kafka-connect-elasticsearch

Star

Kafka Connect Elasticsearch connector

elasticsearch kafka confluent kafka-connect kafka-connector

Updated Dec 22, 2020
Java

confluentinc / cp-helm-charts

Star

Open

Ingresses for services

4

maver1ck commented Aug 13, 2018

Please create ingress template and configuration for:

kafka-rest
kafka-connect
schema-registry

Read more

cp-kafka-connect cp-kafka-rest cp-schema-registry enhancement

Open

Create Test hook to validate Schema Registry Installation success

Open

Create Test hook to validate Zookeeper Installation success

2

ddd-by-examples / all-things-cqrs

Star

Comprehensive guide to a couple of possible ways of synchronizing two states with Spring tools. Synchronization is shown by separating command and queries in a simple CQRS application.

events kafka cqrs spring spring-boot mongodb ddd domain-driven-design kafka-connect debezium

Updated Apr 4, 2019
Java

lensesio / kafka-connect-ui

Star

Web tool for Kafka Connect |

redis mqtt elasticsearch twitter kafka cassandra influxdb jms s3 documentdb hdfs kafka-connect

Updated Dec 10, 2020
JavaScript

simplesteph / kafka-connect-github-source

Star

Get a stream of issues and pull requests for your chosen GitHub repository

github github-api kafka source kafka-connect

Updated Oct 13, 2020
Java

confluentinc / cp-ansible

Star

Ansible playbooks for the Confluent Platform

ansible kafka schema-registry playbook confluent kafka-connect ksql rest-proxy

Updated Dec 23, 2020
HTML

erdemcer / kafka-connect-oracle

Star

Kafka Source Connector For Oracle

kafka oracle kafka-connect kafka-connector logminer

Updated Oct 17, 2020
Java

kaiwaehner / ksql-udf-deep-learning-mqtt-iot

Star

Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data

java open-source mqtt machine-learning kafka deep-learning tensorflow confluent kafka-connect kafka-client h2oai ksql confluent-platform

Updated Apr 22, 2020
Java

kaiwaehner / hivemq-mqtt-tensorflow-kafka-realtime-iot-machine-learning-training-inference

Star

Real Time Big Data / IoT Machine Learning (Model Training and Inference) with HiveMQ (MQTT), TensorFlow IO and Apache Kafka - no additional data store like S3, HDFS or Spark required

Updated Nov 5, 2020
Jupyter Notebook

salesforce / mirus

Star

Mirus is a cross data-center data replication tool for Apache Kafka

kafka kafka-connect mirroring

Updated Oct 12, 2020
Java

mongodb / mongo-kafka

Star

MongoDB Kafka Connector

kafka mongodb avro source kafka-connect bson cdc sink-connector sink source-connector confluent-hub

Updated Dec 15, 2020
Java

confluentinc / kafka-connect-storage-cloud

Star

Kafka Connect suite of connectors for Cloud storage (Amazon S3)

aws cloud kafka aws-s3 s3 confluent kafka-connect

Updated Dec 22, 2020
Java

hpgrahsl / kafka-connect-mongodb

Star

**Unofficial / Community** Kafka Connect MongoDB Sink Connector - Find the official MongoDB Kafka Connector here: https://www.mongodb.com/kafka-connector

json kafka mongodb connector avro kafka-connect bson cdc sink-connector sink change-data-capture debezium cosmosdb azure-cosmosdb confluent-hub

Updated Oct 29, 2020
Java

vdesabou / kafka-docker-playground

Star

Playground for Kafka/Confluent Docker experimentations

kafka kafka-connect confluent-kafka kafka-connectors

Updated Dec 27, 2020
Shell

kaiwaehner / kafka-connect-iot-mqtt-connector-example

Star

Internet of Things Integration Example => Apache Kafka + Kafka Connect + MQTT Connector + Sensor Data

mqtt iot opensource kafka internet-of-things mqtt-broker confluent kafka-connect mosquitto kafka-connector mqtt-connector confluent-kafka confluent-platform

Updated Mar 17, 2020
Shell

lensesio / kafka-connect-tools

Star

Kafka Connect Tooling

cli kafka kafka-connect

Updated May 13, 2020
Scala

jcustenborder / kafka-connect-spooldir

Star

Kafka Connect connector for reading CSV files into Kafka.

json csv kafka-connect

Updated Dec 7, 2020
Java

nodefluent / kafka-connect

Star

equivalent to kafka-connect 🔧 for nodejs ✨

🐢

🚀

✨

nodejs framework kafka etl connect kafka-connect datastore

Updated Dec 18, 2020
JavaScript

qubole / streamx

Star

kafka-connect-s3 : Ingest data from Kafka to Object Stores(s3)

aws streaming kafka big-data connector s3 gcp gcs kafka-connect

Updated Apr 4, 2019
Java

mtpatter / postgres-kafka-demo

Star

Fully reproducible step-by-step demo on how to stream tables from Postgres to Kafka/KSQL back to Postgres

streaming kafka postgresql kafka-connect debezium ksql ksql-server

Updated Mar 12, 2019
Dockerfile

itadventurer / kafka-backup

Star

Backup and Restore for Apache Kafka

backup kafka kafka-connect

Updated Nov 8, 2020
Java

mmolimar / kafka-connect-fs

Star

Kafka Connect FileSystem Connector

files kafka hadoop filesystem ftp s3 gcp confluent hdfs kafka-connect apache-kafka azure-storage kafka-connector hadoop-filesystem kafka-connect-fs

Updated Sep 15, 2020
Java

jcustenborder / kafka-connect-twitter

Star

Kafka Connect connector to stream data in real time from Twitter.

twitter kafka-connect

Updated Aug 14, 2019
Java

Improve this page

Add a description, image, and links to the kafka-connect topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the kafka-connect topic, visit your repo's landing page and select "manage topics."

You can’t perform that action at this time.