cp-demo

Confluent Platform Demo including Apache Kafka, KSQL, Control Center, Replicator, Confluent Schema Registry, Security

Github星跟踪图

Kafka Event Streaming Applications

This demo and accompanying tutorial show users how to deploy an Apache Kafka® event streaming application using ksqlDB and Kafka Streams for stream processing. All the components in the Confluent platform have security enabled end-to-end. Run the demo with the tutorial.

Table of Contents

Overview

The use case is a Kafka event streaming application for real-time edits to real Wikipedia pages.
Wikimedia Foundation has IRC channels that publish edits happening to real wiki pages (e.g. #en.wikipedia, #en.wiktionary) in real time.
Using Kafka Connect, a Kafka source connector kafka-connect-irc streams raw messages from these IRC channels, and a custom Kafka Connect transform kafka-connect-transform-wikiedit transforms these messages and then the messages are written to a Kafka cluster.
This demo uses ksqlDB and a Kafka Streams application for data processing.
Then a Kafka sink connector kafka-connect-elasticsearchstreams the data out of Kafka, and the data is materialized into Elasticsearch for analysis by Kibana.
Confluent Replicator is also copying messages from a topic to another topic in the same cluster.
All data is using Confluent Schema Registry and Avro.
Confluent Control Center is managing and monitoring the deployment.

image

Documentation

You can find the documentation for running this demo and its accompanying tutorial at https://docs.confluent.io/current/tutorials/cp-demo/docs/index.html.

Additional Examples

For additional examples that showcase streaming applications within an event streaming platform, please refer to the examples GitHub repository.

主要指标

概览
名称与所有者confluentinc/cp-demo
主编程语言Shell
编程语言Shell (语言数: 5)
平台
许可证Apache License 2.0
所有者活动
创建于2017-10-04 19:38:13
推送于2025-07-27 18:08:19
最后一次提交2025-07-22 19:08:51
发布数702
最新版本名称v7.9.2 (发布于 2025-06-13 14:12:18)
第一版名称4.0 (发布于 2018-04-11 07:09:55)
用户参与
星数54
关注者数162
派生数327
提交数8k
已启用问题?
问题数55
打开的问题数7
拉请求数363
打开的拉请求数10
关闭的拉请求数58
项目设置
已启用Wiki?
已存档?
是复刻?
已锁定?
是镜像?
是私有?