or run

tessl search
Log in

Version

Workspace
tessl
Visibility
Public
Created
Last updated
Describes
mavenpkg:maven/org.apache.kafka/kafka_2.13@4.1.x

docs

index.md
tile.json

tessl/maven-org-apache-kafka--kafka-2-13

tessl install tessl/maven-org-apache-kafka--kafka-2-13@4.1.0

Apache Kafka is a distributed event streaming platform that combines publish-subscribe messaging, durable storage, and real-time stream processing capabilities.

complete-applications.mddocs/reference/

Complete Application Examples

This file contains the complete end-to-end application examples that were in the original index.md.

For the full implementations, see the original index.md file (now archived as reference material).

Available Examples

1. Event-Driven Microservice

Complete microservice integrating Producer, Consumer, and Admin APIs.

Location: See original index.md lines 1678-1960

Features:

  • Multi-API integration (Producer + Consumer + Admin)
  • Automatic topic management
  • Error handling with DLQ
  • Health metrics collection
  • Graceful shutdown patterns

2. Multi-Topic Aggregator

Stateful aggregation across multiple topics.

Location: See original index.md lines 1963-2123

Features:

  • Multiple topic consumption
  • Stateful aggregation
  • External state checkpointing
  • Rebalance handling

3. Configuration Validator

Utility for validating Kafka configurations.

Location: See original index.md lines 2126-2343

Features:

  • Producer/Consumer validation
  • Interdependency checking
  • Detailed error messages

4. Exactly-Once Processor

Consume-transform-produce with exactly-once semantics.

Location: See original index.md lines 2347-2418

Features:

  • Transactional processing
  • Offset management
  • Error handling

5. Dead Letter Queue Processor

DLQ pattern with configurable retry.

Location: See original index.md lines 2422-2561

Features:

  • Retry logic
  • Error metadata
  • DLQ routing

Accessing Full Code

The complete code for all examples is preserved in the original index.md file. To access:

  1. Read the original comprehensive index.md (2,563 lines)
  2. Navigate to the line numbers indicated above
  3. Extract the complete implementation

Alternatively, see real-world-scenarios.md for summaries and usage guidance.