iluwatar / iluwatar/java-design-patterns

Kappa Architecture

Open
#892 15 comments 1 reaction 0 assignees View on GitHub

Nobody has claimed this yet.

epic: pattern info: help wanted type: feature
Dominant language
Java
Stars
94.7k
Forks
27.4k
Avg merge
3d 4h
Merged PRs (30d)
10

Description

Description:
The Kappa Architecture is a data processing architecture that provides a simplified approach to handling both real-time and batch data processing. Unlike the Lambda Architecture, which requires separate paths for batch and real-time processing, the Kappa Architecture uses a single stream processing engine for both real-time and historical data processing.

Main elements of the Kappa Design Pattern include:

  • Single Data Pipeline: A unified data processing stream that handles both real-time and historical data.
  • Stream Processing Engine: A core component that processes incoming data in real-time.
  • Immutable Data Store: All data is stored in an immutable, append-only log, ensuring data integrity and enabling easy reprocessing.
  • Reprocessing Capability: The ability to reprocess historical data by replaying the log.

References:

  1. Kappa Architecture by Milinda Pathirage
  2. Kappa Architecture GitHub Repository
  3. Java Design Patterns Contribution Guidelines

Acceptance Criteria:

  1. Implement a single data pipeline that processes both real-time and historical data.
  2. Integrate a stream processing engine to handle incoming data in real-time.
  3. Ensure that the data store is immutable and supports reprocessing of historical data by replaying the log.

Contributor guide

Open the contributing guide

First steps

  1. Read the whole issue, then the project's contributing guide.
  2. Comment on the issue to say you are picking it up — it saves two people doing the same work.
  3. Fork the repository and make your change on a branch.
  4. Open a pull request that references the issue number.

Research direction

No source files, tests, or entry points are named; start by reviewing the referenced Kappa Architecture material and the Java Design Patterns contribution guidelines. Define the implementation scope from the repository's existing patterns, with completion requiring the single pipeline, real-time stream processing, immutable log, and historical replay described in the acceptance criteria.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
data-engineering, distributed-systems, stream-processing
Issue type
Feature
Difficulty
5/5
Estimated time
Over a week
Activity status
Stale
Clarity
Needs clarification
Newbie friendliness
25/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.