confluentinc/examples

View on GitHub

Apache Kafka, Apache Flink and Confluent Platform examples and demos

Stars: 2.1k
Forks: 1.1k
Open beginner issues: 0
Indexed issues: 86

Dominant language: Java
License: Apache-2.0
Last GitHub push: Aug 7, 2026
Latest indexed: Sep 15, 2026
Contributing guide: No contributing guide
Code of conduct: No code of conduct
Beginner labels: No beginner labels indexed
PR merge metrics: No merged PRs in 30d

Open All

86 open issues indexed

Consider adding Storage Connectors Open

confluentinc/examples#25 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
[clients/avro] Avro IDL example Open

confluentinc/examples#61 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
[clients/avro] Avro ReflectData example Open

confluentinc/examples#62 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
docker-compose_ksql-server_1 and docker-compose_datagen-ratings_1 exiting while running docker Open

confluentinc/examples#130 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Easy working sample with mssql Open

confluentinc/examples#152 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Make it work with Elasticsearch 7.1 Open

confluentinc/examples#173 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
FraudService solution has NPE and also doesn't aggregate first order in the method simpleMerge Open

confluentinc/examples#281 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Kafka connect doesn't start Open

confluentinc/examples#289 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
docker-compose_kafka-connect-cp does not start ? Open

confluentinc/examples#334 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
How to configure docker-compose to allow services to access the host internet? Open

confluentinc/examples#350 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
microservices-orders example can you create it in rust? or rust microservices example with business logic Open

confluentinc/examples#385 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Error while creating ephemeral in docker Open

confluentinc/examples#390 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Timeout connecting to Confluent Kafka: -185 error Open

confluentinc/examples#395 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Under Replicated Partition in Multi-region docker-compose setup Open

confluentinc/examples#402 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
MultiRegion Snapshot Manifest not found Open

confluentinc/examples#424 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Cannot start service sqlite: OCI runtime create failed Open

confluentinc/examples#442 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Example: Can't created CUSTOMERS_SRC stream Open

confluentinc/examples#480 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Multiple Interceptor for Kafka Producer is not working Open

confluentinc/examples#493 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
DEVX-1138: Kafka Streams IQ tutorial Open

confluentinc/examples#540 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Windows: .env file problem with cp-all-in-one and cp-all-in-one-community Open

confluentinc/examples#565 · 1 comment · 2 reactions · 0 assignees · Indexed Sep 15, 2026
url to cloud is vague Open

confluentinc/examples#571 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
ccloud login Open

confluentinc/examples#572 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Kafka connect Sql multiple connector Instances Open

confluentinc/examples#613 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Salesforce Sink SObject Connector - Error Bad Kafka SinkRecord. Value is not of type Struct. Kafka topics are not in the format the connector is expecting. Open

confluentinc/examples#619 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Example does not specify timeouts that need to be set Open

confluentinc/examples#643 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
partitions mismatch for pageview Open

confluentinc/examples#647 · 8 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
ccloud_lib.py throws error if there is a new line in the librdkafka.config file Open

confluentinc/examples#661 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Enhance the clickstream ksqlDB demo to create connectors using ksqlDB Open

confluentinc/examples#668 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Add automated testing for examples Open

confluentinc/examples#669 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
KSQL Music APP: docker-compose up -d not working Open

confluentinc/examples#674 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Confluent Cloud SSL handshake failed Open

confluentinc/examples#682 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Unable to connect local Kafka Connect to Confluent Cloud Open

confluentinc/examples#691 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
[Android] Consumer/Producer Open

confluentinc/examples#700 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Json Schema application Examples Open

confluentinc/examples#701 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
A confluent -control-Center was not found in the 4.1.2 release Open

confluentinc/examples#703 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
where to raise issue for Kafka SFTP connector? Open

confluentinc/examples#710 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
IBM BAI - Confluent Kafka configuration issue Open

confluentinc/examples#712 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Errors running KSQL-Datagen with secured Schema Registry Open

confluentinc/examples#738 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
(un)subscription on topics Open

confluentinc/examples#747 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
KSQL Statements Should now include "EMIT CHANGES" for ksqlDB (.sql files) Open

confluentinc/examples#756 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
examples/music does not appear to create topics Open

confluentinc/examples#785 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Examples ccloud : ksqlDB queries : you now need to project key columns in value schema Open

confluentinc/examples#804 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Examples Should Avoid Using Schema Registry for Keys Open

confluentinc/examples#817 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
examples/clickstream Open

confluentinc/examples#833 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Running Confluent Control Center against Azure Event Hubs Open

confluentinc/examples#866 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
examples/microservices-orders Windows WSL2 Open

confluentinc/examples#868 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Env file (.env) redirect not working on Linux (Ubuntu 16) Open

confluentinc/examples#1010 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Confusing step as viewing code Open

confluentinc/examples#1018 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Confluent Replicator Demo Issue: Reporting error "Waiting up to 180 seconds for Connect to start" Open

confluentinc/examples#1019 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Need for AWS_PROFILE is confusing Open

confluentinc/examples#1027 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026

confluentinc/examples

Get new issues in your inbox