/spring-boot-kafka-bank-balance-exactly-once

Primary LanguageJava

Bank Balance Exactly Once

This is an implementation of exercise: Bank Balance in Udemy course: Apache Kafka Series - Kafka Streams for Data Processing.

Tech Stack

  • Spring Boot
  • Kafka Stream
  • Kafka
  • Gradle

Description

This exercise is focusing on the Exactly-once semantics of Kafka.

  1. BankTransactionsProducer produces three transactions per second to topic bank-transaction.
  2. Stream application transaction-update-stream receives transactions and updates balance by counting the number of transaction, aggregating amount, and updating time to the latest time, and finally sends the balance to bank-balance topic.
  3. BankBalanceConsumer consumes the balance and logs to screen.

WARNING: this might not be the best practice.

Run

You need to have a kafka bootstrap-server running at localhost:9092.

gradle bootRun