# varmavetukuri1986/confluent-kafka-certification architecture

> Architecture diagram of the GitHub repository varmavetukuri1986/confluent-kafka-certification, generated by GitDiagram from its file tree, README and a sample of source files (last updated 2026-11-12). It is an AI-made overview: check details against the source.

- Interactive diagram: https://gitdiagram.com/varmavetukuri1986/confluent-kafka-certification
- Repository: https://github.com/varmavetukuri1986/confluent-kafka-certification

## Overview

This repository is a CCDAK study collection with a small, runnable Kafka producer demo—not one integrated application. Its main executable workflow starts in the producer main, constructs a custom producer, and sends a keyed message to a Kafka topic. A separate Avro example publishes a customer record and configures Schema Registry. The README indexes additional study areas for consumers, Connect, Streams, KSQL, and Kafka core. Those are documented as learning branches; their internal runtime relationships are not established by the sampled source.

Main entry points: [`README.md`](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/README.md) (Topic Index), [`kafka-streams/README.md`](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-streams/README.md) (Streams Guide), [`kafka-schema-registry/src/main/java/com/varma/kafka/KafkaProducerMain.java`](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-schema-registry/src/main/java/com/varma/kafka/KafkaProducerMain.java) (Avro Producer Main), [`kafka-producer/src/main/java/com/varma/kafka/KafkaProducerMain.java`](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-producer/src/main/java/com/varma/kafka/KafkaProducerMain.java) (Producer Main)

## Diagram (Mermaid)

```mermaid
flowchart TD

subgraph group_study["Study Guides"]
  node_index["Topic Index<br/>[README.md]"]
  node_setup["Setup Commands"]
  node_core["Kafka Core Guide"]
  node_consumer["Consumer Guide<br/>[README.md]"]
  node_connectors["Connect Guide<br/>[README.md]"]
  node_streams["Streams Guide<br/>[README.md]"]
  node_processor["Processor API Guide"]
  node_streamsdsl["Streams DSL Guide"]
  node_ksql["KSQL Guide<br/>[README.md]"]
  node_producerreadme["Producer Guide<br/>[README.md]"]
  node_registryreadme["Registry Guide<br/>[README.md]"]
end

subgraph group_demo["Producer Demos"]
  node_producerentry["Producer Main"]
  node_customproducer["Custom Producer"]
  node_avroentry["Avro Producer Main"]
end

subgraph group_platform["Kafka Platform"]
  node_broker[("Kafka Broker")]
  node_registry["Schema Registry"]
end

node_learner(("Learner"))

node_learner -->|"opens"| node_index
node_index -->|"links to"| node_setup
node_index -->|"links to"| node_core
node_index -->|"links to"| node_consumer
node_index -->|"links to"| node_connectors
node_index -->|"links to"| node_streams
node_index -->|"links to"| node_ksql
node_index -->|"links to"| node_producerreadme
node_index -->|"links to"| node_registryreadme
node_streams -->|"links to"| node_processor
node_streams -->|"links to"| node_streamsdsl
node_learner -.->|"runs"| node_producerentry
node_producerentry -->|"calls"| node_customproducer
node_customproducer -->|"sends record"| node_broker
node_learner -.->|"runs"| node_avroentry
node_avroentry -->|"sends record"| node_broker
node_avroentry -->|"configures"| node_registry

click node_index "https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/README.md"
click node_setup "https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/SETUP-COMMANDS-README.md"
click node_core "https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/KAFKA-CORE-README.md"
click node_consumer "https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-consumer/README.md"
click node_connectors "https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-connectors/README.md"
click node_streams "https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-streams/README.md"
click node_processor "https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-streams/Processor-api-README.md"
click node_streamsdsl "https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-streams/kafka-DSL-README.md"
click node_ksql "https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-ksql/README.md"
click node_producerreadme "https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-producer/README.md"
click node_registryreadme "https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-schema-registry/README.md"
click node_producerentry "https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-producer/src/main/java/com/varma/kafka/KafkaProducerMain.java"
click node_customproducer "https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-producer/src/main/java/com/varma/kafka/CustomKafkaProducer.java"
click node_avroentry "https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-schema-registry/src/main/java/com/varma/kafka/KafkaProducerMain.java"

classDef toneNeutral fill:#f8fafc,stroke:#334155,stroke-width:1.5px,color:#0f172a
classDef toneBlue fill:#dbeafe,stroke:#2563eb,stroke-width:1.5px,color:#172554
classDef toneAmber fill:#fef3c7,stroke:#d97706,stroke-width:1.5px,color:#78350f
classDef toneMint fill:#dcfce7,stroke:#16a34a,stroke-width:1.5px,color:#14532d
classDef toneRose fill:#ffe4e6,stroke:#e11d48,stroke-width:1.5px,color:#881337
classDef toneIndigo fill:#e0e7ff,stroke:#4f46e5,stroke-width:1.5px,color:#312e81
classDef toneTeal fill:#ccfbf1,stroke:#0f766e,stroke-width:1.5px,color:#134e4a
class node_index,node_setup,node_core,node_consumer,node_connectors,node_streams,node_processor,node_streamsdsl,node_ksql,node_producerreadme,node_registryreadme toneBlue
class node_producerentry,node_customproducer,node_avroentry toneAmber
class node_broker,node_registry toneMint
class node_learner toneIndigo
```

## Components

### Study Guides

- [Topic Index](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/README.md): `README.md`
- [Setup Commands](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/SETUP-COMMANDS-README.md): `SETUP-COMMANDS-README.md`
- [Kafka Core Guide](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/KAFKA-CORE-README.md): `KAFKA-CORE-README.md`
- [Consumer Guide](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-consumer/README.md): `kafka-consumer/README.md`
- [Connect Guide](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-connectors/README.md): `kafka-connectors/README.md`
- [Streams Guide](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-streams/README.md): `kafka-streams/README.md`
- [Processor API Guide](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-streams/Processor-api-README.md): `kafka-streams/Processor-api-README.md`
- [Streams DSL Guide](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-streams/kafka-DSL-README.md): `kafka-streams/kafka-DSL-README.md`
- [KSQL Guide](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-ksql/README.md): `kafka-ksql/README.md`
- [Producer Guide](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-producer/README.md): `kafka-producer/README.md`
- [Registry Guide](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-schema-registry/README.md): `kafka-schema-registry/README.md`

### Producer Demos

- [Producer Main](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-producer/src/main/java/com/varma/kafka/KafkaProducerMain.java): `kafka-producer/src/main/java/com/varma/kafka/KafkaProducerMain.java`
- [Custom Producer](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-producer/src/main/java/com/varma/kafka/CustomKafkaProducer.java): `kafka-producer/src/main/java/com/varma/kafka/CustomKafkaProducer.java`
- [Avro Producer Main](https://github.com/varmavetukuri1986/confluent-kafka-certification/blob/master/kafka-schema-registry/src/main/java/com/varma/kafka/KafkaProducerMain.java): `kafka-schema-registry/src/main/java/com/varma/kafka/KafkaProducerMain.java`

### Kafka Platform

- **Kafka Broker**
- **Schema Registry**

### Other components

- **Learner**

## Connections

- Learner → Topic Index: opens (evidence: `README.md`)
- Topic Index → Setup Commands: links to (evidence: `README.md`)
- Topic Index → Kafka Core Guide: links to (evidence: `README.md`)
- Topic Index → Consumer Guide: links to (evidence: `README.md`)
- Topic Index → Connect Guide: links to (evidence: `README.md`)
- Topic Index → Streams Guide: links to (evidence: `README.md`)
- Topic Index → KSQL Guide: links to (evidence: `README.md`)
- Topic Index → Producer Guide: links to (evidence: `README.md`)
- Topic Index → Registry Guide: links to (evidence: `README.md`)
- Streams Guide → Processor API Guide: links to
- Streams Guide → Streams DSL Guide: links to
- Learner → Producer Main: runs
- Producer Main → Custom Producer: calls (evidence: `kafka-producer/src/main/java/com/varma/kafka/KafkaProducerMain.java`)
- Custom Producer → Kafka Broker: sends record (evidence: `kafka-producer/src/main/java/com/varma/kafka/CustomKafkaProducer.java`)
- Learner → Avro Producer Main: runs
- Avro Producer Main → Kafka Broker: sends record (evidence: `kafka-schema-registry/src/main/java/com/varma/kafka/KafkaProducerMain.java`)
- Avro Producer Main → Schema Registry: configures (evidence: `kafka-schema-registry/src/main/java/com/varma/kafka/KafkaProducerMain.java`)