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/
Requirements
You may well need to allocate Docker 8GB when running these. Avoid allocating all your machine's cores to Docker as this may cause the machine to become unresponsive when running large stacks. On a four-core Mac Book two cores for Docker should be fine.
Contents
Livestreams
Applications
- Building a Telegram bot with Go, Apache Kafka, and ksqlDB (
�� talk) - Streaming Pac-Man
- Workshop: Event Driven Microservices
- Workshop: Choosing Christmas Movies with Kubernetes, Spring Boot, and Apache Kafka (
�� recording) - Kafka Summit NYC: Confluent Operator Demo aka Escape from EKS
- Kafka Summit 2020 - I don’t always test my streams, but when I do, I do it in production!
- Apache Kafka® Event Streaming Platform For Kotlin Developers (
�� recording)
Data pipelines (Database + KSQL + Elasticsearch)
- Streaming ETL and Analytics on Confluent with Maritime AIS data
- Pipeline to the cloud - on-premises RDBMS to Cloud datawarehouse e.g. Snowflake (
✍️ blog) - Rail data streaming pipeline (
��️ talk) - Apache Kafka and KSQL in Action: Let’s Build a Streaming Data Pipeline! (
��️ talk) - MySQL / Debezium CDC / KSQL / Elasticsearch
- Oracle CDC / KSQL / Elasticsearch
- Postgres / Debezium CDC / KSQL / Elasticsearch
- CDC demo with MySQL (
��️ talk) - CDC demo with Oracle
- Building data pipelines with Confluent Cloud and GCP (BigQuery, GCS, etc)
- MS SQL with Debezium and ksqlDB (
✍️ blog) - Streaming ETL pipeline from MongoDB to Snowflake with Apache Kafka®
- Bridge to Cloud (and back!) with Confluent and MongoDB Atlas
ksqlDB (previously known as KSQL)
- Introduction to ksqlDB 01 (
��️ talk) - Introduction to KSQL 02
- ksqlDB tombstones
- Using Twitter data with ksqlDB
- KSQL UDF Advanced Example
- KSQL Troubleshooting
- ATM Fraud detection with Kafka and KSQL (
��️ talk) - Kafka Streams/KSQL Movie Demo
- KSQL MQTT demo
- KSQL Dump Utility
- KSQL workshop (more recent version is here)
- Multi-node ksqlDB and Kafka Connect clusters
- Streaming ETL pipeline from MongoDB to Snowflake with Apache Kafka®
- Bridge to Cloud (and back!) with Confluent and MongoDB Atlas
- Confluent + IBM Demo Read data from IBM MQ and IBM DB2, join with ksqlDB, sink to IBM MQ
Kafka Connect
- Single Message Transform in Kafka Connect
- Improvements Kafka Connect in Apache Kafka 2.3
- From Zero to Hero with Kafka Connect (
��️ talk) - Kafka Connect Converters and Serialization (
✍️ blog) - Building a Kafka Connect cluster
- Kafka Connect error handling (
✍️ blog) - Multi-node ksqlDB and Kafka Connect clusters
- Specific connectors
-
�� S3 Sink (�� tutorial) -
�� Database (tutorial�� 1 /�� 2) -
�� Elasticsearch (�� Tutorial) - RSS feed into Kafka
- Loading CSV data into Kafka (
�� Tutorial) - Loading XML data into Kafka
- Kafka Connect JDBC Source demo environment (
✍️ blog) - InfluxDB & Kafka Connect (
✍️ blog) - RabbitMQ into Kafka (
✍️ blog) - MQTT Connect Connector Demo
- Example Kafka Connect syslog configuration and Docker Compose (see blog series 1/2/3 and standalone articles here and here)
- Azure SQL Data Warehouse Connector Sink Demo
- Confluent + IBM Demo Read data from IBM MQ and IBM DB2, join with ksqlDB, sink to IBM MQ
- Solace Sink/Source Demo
-
Confluent Cloud
- Getting Started with Confluent Cloud using Java
- Getting Started with Confluent Cloud using Go
- Streaming Pac-Man
- "The Cube" Demo
- Using Replicator with Confluent Cloud
- Streaming ETL pipeline from MongoDB to Snowflake with Apache Kafka®
- Micronaut & AWS Lambda on Confluent Cloud
- Bridge to Cloud (and back!) with Confluent and MongoDB Atlas
- Random Pizza Generator with Micronaut on Confluent Cloud
Confluent Platform
- Self-Balancing Clusters Demo
- Tiered Storage Demo
- Cluster Linking Demo
- Confluent Admin REST APIs Demo
- CP-Ansible on Ansible Tower
Misc
- Kafka as a Platform: the Ecosystem from the Ground Up (
�� recording) - Hacky export/import between Kafka clusters using
kafkacat - Docker Compose for just the community licensed components of Confluent Platform
- Topic Tailer, stream topics to the browser using websockets
- KPay payment processing example
- Industry themes (e.g. banking Next Best Offer)
- Distributed tracing
- Analysing Sonos data in Kafka (
✍️ blog) - Analysing Wi-Fi pcap data with Kafka
- Twitter streams and Operator
- Produce Test Kafka Data
Feedback & Questions
- Bugs/issues with demo: raise an issue on this github project
- General question/assistance: https://confluent.io/community/ask-the-community/
-
OpenPose Demo - Overview Forget about the OpenPose library code, just compile the library and use the demo ./build/examples/openpose/openpose.bin. In order to learn how to use it, run ./build/examples
-
整个初始化步骤: 1. Create the ID3D12Device using the D3D12CreateDevice function. 2. Create an ID3D12Fence object and query descriptor sizes. 3. Check 4X MSAA quality level support. 4. Create the command queu
-
描述 (Description) Abide在HTML5表单验证库中使用本机API，使用必需的属性和模式。 例子 (Example) 以下示例演示了在Foundation中使用abide插件 - <!DOCTYPE html> <html> <head> <title>Foundation Template</title> <meta name = "viewport
-
jfinal demo 程序，使用bootstrap+本人编写的多款插件，如使用coffeescript-maven-plugin编译coffeescript代码，使用lesscsss-maven-plugin编译lesscss代码，使用flyway-maven-plugin运行数据库脚本，支持多种定制功能。 运行指南： 1.在mysql里创建数据库jfinal_demo,运行maven插件 c
-
一个使用ZXing库实现二维码扫描、自定义扫描控件及二维码生成的例子。项目中包含了ZXing自带扫描控件的使用，自定义扫描控件的界面，从相册中读取照片解析二维码，以及生成二维码的功能。解码使用ZXing库，编码使用QRCodeEncoder库。 [Code4App.com]
-
前言 vue2正式版已经发布将近一个月了， 国庆过后就用在了公司的两个正式项目上， 还有一个项目下个月也会采用vue2进行重构 选择它没什么理由，如果非要说一个理由 那就是它的中文文档远比react，angularjs要友好 github:https://github.com/lzxb/vue2-demo 源码说明 项目目录说明 .|-- config
-
本教程结合SSM（SpringMVC + Mybatis）框架讲解Shiro（Shiro是 Java 的一个安全框架。我们经常看到它被拿来和 Spring 的 Security 来对比。），讲解的内容有自定义Shiro拦截器，Shiro Freemarker标签，Shiro JSP标签，权限控制讲解，并提供Shiro Demo下载。 Shiro Demo环境准备 开发工具：Eclipse、M
-
Quick Start 联系作者 十三的java学习交流QQ群:881582471，658365129(已满) 宣传 十三近期于CSDN上传了一份自己制作的达人课课程,感兴趣的朋友可以看一下： GitChat达人课-SSM搭建精美实用的管理系统 项目简介 ssm系列 ssm-demo:Spring+SpringMVC+Mybatis+easyUI整合 perfect-ssm：RESTful API