Giter Club home page Giter Club logo

sarwarbhuiyan / examples Goto Github PK

View Code? Open in Web Editor NEW

This project forked from confluentinc/examples

0.0 1.0 0.0 33.66 MB

Apache Kafka and Confluent Platform examples and demos

License: Apache License 2.0

Shell 27.19% SQLPL 0.45% Makefile 3.18% Java 12.41% PLpgSQL 0.48% Python 4.21% Scala 1.02% Ruby 0.70% Go 0.89% Kotlin 1.04% Groovy 1.23% Dockerfile 0.10% JavaScript 0.86% C# 0.80% Emacs Lisp 0.01% C 5.67% TSQL 38.50% Rust 0.62% Clojure 0.49% Smarty 0.15%

examples's Introduction

image

Demos

This is a curated list of demos that showcase Apache Kafka® event stream processing on the Confluent Platform, an event stream processing platform that enables you to process, organize, and manage massive amounts of streaming data across cloud, on-prem, and serverless deployments.

Where to start

The best demo to start with is cp-demo which spins up a Kafka event streaming application using KSQL for stream processing, with many security features enabled, in an end-to-end streaming ETL pipeline with a source connector pulling from live IRC channels and a sink connector connecting to Elasticsearch and Kibana for visualizations. cp-demo also comes with a playbook and is a great configuration reference for Confluent Platform.

Full demo list

Confluent Cloud

Demo Local Docker Description
Beginner Cloud Y N Fully scripted demo that shows how to interact with your Confluent Cloud cluster and set ACLs using the CLI
Clients to Cloud Y N Client applications in different programming languages connecting to Confluent Cloud
GCP pipeline N Y Work with Confluent Cloud to build cool pipelines into Google Cloud Platform (GCP)
Kinesis to Cloud Y N AWS Kinesis -> Confluent Cloud -> Google Cloud Storage pipeline
On-Prem Kafka to Cloud Y Y This more advanced demo showcases an on-prem Kafka cluster and Confluent Cloud cluster, and data copied between them with Confluent Replicator
GKE to Cloud N Y Uses Google Kubernetes Engine, Confluent Cloud, and Confluent Replicator to explore a multicloud deployment

Stream Processing

Demo Local Docker Description
Clickstream Y Y Automated version of the KSQL clickstream demo
Kafka Tutorials Y Y Collection of common event streaming use cases, with each tutorial featuring an example scenario and several complete code solutions
KSQL UDF Y N Advanced KSQL User-Defined Function (UDF) use case for connected cars
KSQL workshop N Y showcases Kafka event stream processing using KSQL and can run self-guided as a KSQL workshop
Microservices ecosystem Y N Microservices orders Demo Application integrated into the Confluent Platform
Music demo Y Y KSQL version of the Kafka Streams Demo Application

Data Pipelines

Demo Local Docker Description
CDC with MySQL N Y Self-paced steps to set up a change data capture (CDC) pipeline
CDC with Postgres N Y Enrich event stream data with CDC data from Postgres and then stream into Elasticsearch
Connect and Kafka Streams Y N Demonstrate various ways, with and without Kafka Connect, to get data into Kafka topics and then loaded for use by the Kafka Streams API
MQTT Y N Internet of Things (IoT) integration example using Apache Kafka + Kafka Connect + MQTT Connector + Sensor Data
MySQL and Debezium Y Y End-to-end streaming ETL with KSQL for stream processing using the Debezium Connector for MySQL
Syslog N Y Real-time syslog processing with Apache Kafka and KSQL: filtering logs, event-driven alerting, and enriching events

Confluent Platform

Demo Local Docker Description
Avro Y N Client applications using Avro and Confluent Schema Registry
CP Demo Y Y Confluent Platform demo with a playbook for Kafka event streaming ETL deployments
Kubernetes N Y Demonstrations of Confluent Platform deployments using the Confluent Operator
Multi Datacenter N Y Active-active multi-datacenter design with two instances of Confluent Replicator copying data bidirectionally between the datacenters
Quickstart Y Y Automated version of the Confluent Platform Quickstart
Role-Based Access Control Y Y Role-based Access Control (RBAC) provides granular privileges for users and service accounts
Secret Protection Y Y Secret Protection feature encrypts secrets in configuration files
Replicator Security N Y Demos of various security configurations supported by Confluent Replicator and examples of how to implement them

Build Your Own

As a next step, you may want to build your own custom demo or test environment. We have several resources that launch just the services in Confluent Platform with no pre-configured connectors, data sources, topics, schemas, etc. Using these as a foundation, you can then add any connectors or applications.

  • cp-all-in-one: This Docker Compose file launches all services in Confluent Platform, and runs them in containers in your local host.
  • cp-all-in-one-cloud: Use this with your pre-configured Confluent Cloud instance. This Docker Compose file launches all services in Confluent Platform (except for the Kafka brokers), runs them in containers in your local host, and automatically configures them to connect to Confluent Cloud.
  • Confluent CLI: For local, non-Docker installs of Confluent Platform. Using this CLI, you can launch all services in Confluent Platform with just one command confluent local start, and they will all run on your local host.
  • Generate test data: "Hello, World!" for launching Confluent Platform, plus different ways to generate more interesting test data for your topics

Additional documentation: Getting Started

Prerequisites

For local installs:

  • Download Confluent Platform 5.3
  • Env var CONFLUENT_HOME=/path/to/confluentplatform
  • Env var PATH includes $CONFLUENT_HOME/bin
  • Each demo has its own set of prerequisites as well, documented individually in each demo

For Docker: demos have been validated with

examples's People

Contributors

ybyzek avatar joel-hamill avatar maxzheng avatar rspurgeon avatar rmoff avatar confluentjenkins avatar dnozay avatar xli1996 avatar brianbushree avatar ewencp avatar thomaskwscott avatar elizabethschafle avatar jimgalasyn avatar edenhill avatar wheresalice avatar colinhicks avatar danphanley avatar frankgreco avatar frankscholten avatar jakeweidokal avatar jonchiu avatar smiles-krishna avatar mhowlett avatar michaelhussey avatar p3tecracknell avatar rodesai avatar spena avatar shayelkin avatar stanislavkozlovski avatar nicolasguyomar avatar

Watchers

James Cloos avatar

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. 📊📈🎉

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google ❤️ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.