confluentinc/kafka-tutorials

View on GitHub

Tutorials and Recipes for Apache Kafka

Stars: 39
Forks: 91
Open beginner issues: 0
Indexed issues: 239

Dominant language: Java
License: Apache-2.0
Last GitHub push: Oct 14, 2024
Latest indexed: Sep 15, 2026
Contributing guide: Contributing guide
Code of conduct: No code of conduct
Beginner labels: good first issue
PR merge metrics: No merged PRs in 30d

Open All

239 open issues indexed

Streaming K-means Cluster Analysis Open

recipe

confluentinc/kafka-tutorials#9 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Streaming Classifier Open

recipe

confluentinc/kafka-tutorials#10 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Streaming Sentiment Analysis Open

recipe

confluentinc/kafka-tutorials#11 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Aggregations: Count (KStreams) Open

kstreams recipe

confluentinc/kafka-tutorials#13 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Aggregations: element frequency (KSQL) Open

ksqlDB recipe

confluentinc/kafka-tutorials#18 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Aggregations: element frequency (KStreams) Open

recipe

confluentinc/kafka-tutorials#19 · 7 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Rekey a stream (KStreams) Open

recipe

confluentinc/kafka-tutorials#23 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Rekey a stream (Kafka) Open

recipe

confluentinc/kafka-tutorials#24 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Explode an event into many events (KStreams) Open

recipe

confluentinc/kafka-tutorials#25 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Randomly sample a stream (KStreams) Open

recipe

confluentinc/kafka-tutorials#26 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Join two streams (KStreams) Open

recipe

confluentinc/kafka-tutorials#28 · 6 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Join two tables (KStreams) Open

recipe

confluentinc/kafka-tutorials#30 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Deduplicate consecutive events in a stream (KStreams) Open

recipe

confluentinc/kafka-tutorials#31 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Find distinct events in a stream (KStreams) Open

recipe

confluentinc/kafka-tutorials#32 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Create a time window with custom bounds (KStreams) Open

recipe

confluentinc/kafka-tutorials#34 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Create a time window with custom bounds (KSQL) Open

ksqlDB recipe

confluentinc/kafka-tutorials#35 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Using Session Windows (KStreams) Open

recipe

confluentinc/kafka-tutorials#37 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Using Sliding Windows (KSQL) Open

ksqlDB recipe

confluentinc/kafka-tutorials#38 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Using Sliding Windows (KStreams) Open

recipe

confluentinc/kafka-tutorials#39 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Using Hopping Windows (KStreams) Open

recipe

confluentinc/kafka-tutorials#41 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Produce and consume messages to a topic in Java (Kafka) Open

kafka recipe

confluentinc/kafka-tutorials#44 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Produce and consume messages to a topic in Go (Kafka) Open

harness support missing kafka recipe

confluentinc/kafka-tutorials#45 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Produce and consume messages to a topic in Python (Kafka) Open

harness support missing kafka recipe

confluentinc/kafka-tutorials#46 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Produce and consume messages to a topic in C (Kafka) Open

harness support missing kafka recipe

confluentinc/kafka-tutorials#47 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Enforce checkstyle checks Open

enhancement

confluentinc/kafka-tutorials#67 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
migrate to Java 11 Open

enhancement

confluentinc/kafka-tutorials#69 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
Incorporate c3 in recipes Open

enhancement

confluentinc/kafka-tutorials#80 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Shell dependency Open

confluentinc/kafka-tutorials#89 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
harness_runner doesn't write errors from ksql-test-runner to file Open

confluentinc/kafka-tutorials#106 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Filtering based on headers (Kafka Streams) Open

kstreams recipe

confluentinc/kafka-tutorials#110 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Remove textual copy function from tutorials when presenting user command output results Open

enhancement

confluentinc/kafka-tutorials#112 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Add ability to centralize redundant markup Open

enhancement

confluentinc/kafka-tutorials#113 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Create a KStream: console producer -> Key:String and Value:String Open

kstreams recipe

confluentinc/kafka-tutorials#121 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Create a KStream: JDBC source connector with SMT -> Key:Long and Value:JSON Open

connect recipe

confluentinc/kafka-tutorials#122 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Create a KStream: JDBC source connector -> Key:null and Value:GenericAvro Open

connect kstreams recipe

confluentinc/kafka-tutorials#124 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Create a KStream: Java client producer -> Key:Long and Value:SpecificAvro Open

kstreams recipe

confluentinc/kafka-tutorials#125 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
JDBC source connector --> Kafka Streams: handling Decimal types Open

connect kstreams recipe

confluentinc/kafka-tutorials#127 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Produce and consume messages to a topic with CLI: Kafka command line tools Open

kafka recipe

confluentinc/kafka-tutorials#147 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Run client app in Docker container instead of host machine Open

confluentinc/kafka-tutorials#148 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Produce and consume messages to a topic in Ruby (Kafka) Open

harness support missing kafka recipe

confluentinc/kafka-tutorials#149 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Produce and consume messages to a topic in Groovy (Kafka) Open

harness support missing kafka recipe

confluentinc/kafka-tutorials#150 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Produce and consume messages to a topic in Nodejs (Kafka) Open

harness support missing kafka recipe

confluentinc/kafka-tutorials#151 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Produce and consume messages to a topic in Scala (Kafka) Open

kafka recipe

confluentinc/kafka-tutorials#152 · 6 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Produce and Consume messages to a topic in C# (Kafka) Open

harness support missing kafka recipe

confluentinc/kafka-tutorials#153 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Harness should specify tear-down steps explicitly Open

confluentinc/kafka-tutorials#155 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Handle not-found urls Open

confluentinc/kafka-tutorials#160 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Demos for Connect Integration/Pull Queries Open

confluentinc/kafka-tutorials#165 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Inconsistency: aggregating vs aggregate Open

enhancement good first issue

confluentinc/kafka-tutorials#166 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Contributors should be able to leverage CI Open

confluentinc/kafka-tutorials#172 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Handling deserialization error: in Connect Open

recipe

confluentinc/kafka-tutorials#176 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026

confluentinc/kafka-tutorials

Get new issues in your inbox