Skip to content

Spark application, reads credit card transactions from kafka, enriches it by joining with customer MySQL table, apply business rules, write to downstream based on rules

Notifications You must be signed in to change notification settings

mineshmelvin/declined-transactions-analysis

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

5 Commits
 
 
 
 
 
 
 
 

Repository files navigation

Declined Transactions Analysis

This Unit Tested Strongly Typed Spark Scala application is a sort of a simulation of a production application usually used in a financial services sector.

The idea is:

  1. Read declined credit/debit card transactions from a Kafka topic
  2. Read customer data from MySQL table (not complete yet)
  3. Read rules table from MySQL table (not complete yet)
  4. Enrich the transaction data with all required columns
  5. Perform some analysis like total declines per decline_code
  6. Write results to MySQL table, Kafka topic, or console based on the account_type

This is useful if you want to take some near real time actions on the declines. Example: You can send a notification to the customer's card mobile app informing him of the reason for the decline.

About

Spark application, reads credit card transactions from kafka, enriches it by joining with customer MySQL table, apply business rules, write to downstream based on rules

Topics

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages