Recap Series
- Session 01: Modern Trade Lifecycle: Trading to Settlement
- Session 02: Goldman Sachs: Fast Track your applications onto Cloud - AWS FSI Meetup Q1/2023
- Session 03: Zurich Insurance Group: Building an Effective Log Management Solution on AWS
- Session 04: FSI Meetup 2025 Q4 - Brex Database Disaster Recovery
- Session 05: FSI Meetup 2025 Q4 - A Graviton Migration Success Story
- Session 06: FSI Meetup 2025 Q4 - Stifel Modern Data Platform
- Session 07: FSI Meetup 2025 Q4 - Financial Transaction Data Reconciler PayPal
- Session 08: FSI Meetup 2025 Q4 - Scaling Resilience
Session Notes
Introduction to PayPal:
- PayPal is a global payment service provider processing 1.7 trillion in annual payment volume.
- Operates in 200 global markets with 430 million active accounts.
- Processes approximately 900 transactions per second, with peaks during holiday seasons like Black Friday and Cyber Monday.
Critical Problem:
- Ensuring the accuracy and reconciliation of the massive transaction volume.
- Reconciling transactions across multiple systems within PayPal, with external processors, and networks.
- Matching transactions to ensure no data or financial discrepancies.
- Validating that financial records accurately reflect actual customer payments.
Reconciliation Process:
- Transactions flow through PayPal’s system and are recorded in multiple internal ledgers.
- Transactions are sent to external processors for clearing and confirmation by the network.
- PayPal settles the transaction money to the merchant.
- Reconciliation involves matching transactions across PayPal’s internal systems, processor acknowledgments, and funding settlement summaries (end of day, T+1, T+2).
- Primary goal: Ensure transactions are not lost and there are no discrepancies.
Why Reconciliation Matters:
- Three-way matching problem: PayPal internal ledger, external processor records, and network confirmations.
- Critical for financial accuracy and customer trust.
- Ensures that financial records reflect actual customer payments.
High-Level Architecture:
- Focusing on how PayPal achieved near real-time reconciliation.
- Technologies and strategies used to handle the scale and complexity of the problem.
Business Impact:
- Reduction in reconciliation time from 24 hours to 15 minutes.
- Improved accuracy with minimal discrepancies.
- Enhanced customer trust and operational efficiency.
Continued Discussion on PayPal’s Reconciliation System
Three-Way Matching Problem: PayPal Internal Ledger:
- Records transactions within PayPal’s systems.
External Processor:
- Registers transactions in their local system.
Network Confirmation:
- Confirms whether the transaction has been successfully made.
Responsibilities:
- PayPal is responsible for matching transactions at every stage from entry into the system to settlement with the merchant.
- Manual reconciliation is impractical due to the high volume of transactions.
Automated State Machine with Rule Engine:
- Utilizes an automated state machine and high-level rule engine.
- Configured to handle transaction processing with external vendors and timelines for acknowledgments and funding summaries.
- Ensures transactions are reconciled efficiently.
Importance of Reconciliation:
- Critical for understanding "what happened versus what actually happened."
- Ensures transactions are auditable and compliant with regulatory standards (PCI DSS).
- Provides a clear record of when transactions were recorded and settled.
Current Gaps in Legacy System:
- The legacy system relies on end-of-day batch processing.
- Uses a store and process mechanism where transactions accumulate throughout the day and are reconciled at the end of the day.
- Source of truth is not the direct operational data store to avoid performance and latency impacts.
- Utilizes an ETL system sourcing data from Oracle GoldenGate.
- ETL pipeline involves transformation and formatting, leading to potential data mismatches or inconsistencies.
Need for Improvement:
- Move away from batch processing to near real-time processing.
- Reduce reliance on ETL systems to minimize data transformation issues.
- Enhance automation to ensure accurate and timely reconciliation.
Problems with Legacy System:
- Experiences delays due to accommodating all transactions until the end of the day.
- Transactions are matched and account books are closed only at the end of the day.
- This delay is a significant problem.
Objective:
- Transition to a new age platform in the cloud.
- Leverage AWS infrastructure to solve the aforementioned problems.
Key Objectives of the New Solution: End-to-End Data Integrity Across Payment Lifecycle:
- Ensure data integrity from the moment a record enters the real-time payment processing system.
- Track transactions across multiple systems within PayPal.
- Link all transactions with the correct identifier and timestamp.
- Match outbound files sent to processors with inbound records received from networks or vendors.
Automated State-Driven Match Logic:
- Move from a store-and-process mechanism to a stream-and-process mechanism.
- Reduce the entire reconciliation cycle.
Real-Time Monitoring:
- Identify exceptions while matching transactions within the internal system or records from external vendors.
- Record exceptions where matches fail between received records and local ledger transactions.
- Operational team to act on these recorded exceptions.
Technical Architecture: Data Injection:
- Sources from which data is injected into the reconciler.
Reconciliation Process:
- Methods and processes involved in performing reconciliation.
Storage of Reconciliation Outcomes:
- How the results of the reconciliation are stored.
Operational Team Leverage:
- How the operational team uses reconciliation exceptions and acts on them.
High-Level Technical Reconciliation Overview Scope Confinement:
- Upstream payment processing systems are abstracted out.
- Focus starts with the real-time payment card processor.
Real-Time Payment Card Processor:
- Utilizes EKS service to receive millions of transactions per day (expected ~300 million transactions daily).
- Each transaction is recorded in AWS DynamoDB, which serves as the source of truth and operational data store.
Data Flow:
- [ 1 ] DynamoDB to Kinesis Data Stream:
- Transactions recorded in DynamoDB are streamed via Kinesis Data Stream.
- Kinesis manages ordering of transactions.
- [ 2 ] Amazon Data Firehose:
- Transactions are bucketed and chunked based on different business parameters.
- [ 3 ] AWS S3:
- Transactions are recorded in AWS S3.
- S3 acts as a secondary data store for transactions but primary for file processing.
Reconciliation Process:
- [ 1 ] Inbound Transactions in PayPal:
- Processed transactions in PayPal are translated into file format in AWS S3.
- [ 2 ] External Partner Processing:
- Chunk files are translated into files and processed with external partners.
- Inbound records from external partners are returned to S3.
AWS S3 as Central Source:
- S3 holds both internal transaction footprints and external processed transactions received as inbound files.
Data Processing:
- EventBridge Scheduling:
- Triggers Apache Spark on AWS EMR cluster every 15 minutes.
- Distributed processing of transactions in S3 using a preconfigured rule engine.
Rule Engine:
- Comprises multiple state graphs.
- Categorizes transactions and determines terminal states.
- Includes complex rules based on market operations, external partners, and cutoff times for data export/import.
Technical Reconciliation Architecture Apache EMR Cluster and Rule Engine:
- Apache EMR cluster utilizes the rule engine to match transactions.
- Successful reconciliation results are written back to AWS S3.
- Exceptions are sent to AWS EventBridge, which triggers a Lambda function to enrich and report exceptions back to S3.
Storage and Operational Aspects:
- Data stored as parquet files in S3.
- Apache Glue Catalog configured on top of parquet files.
- The operational team can query data using Amazon Athena in SQL fashion.
- Custom-built UI portal on top of Glue Catalog provides detailed reconciliation states and outcomes for specific days, settlements, or partners.
Architecture Highlights: Active-Active Architecture:
- Operates across multiple AWS regions.
- Ensures high availability with zero recovery point objective (RPO) and recovery time objective (RTO).
- If one region goes down, another can process transactions seamlessly.
- In-flight transactions are managed using Amazon Kinesis Data Stream and DynamoDB for consistency across regions.
Technology and Architecture Decisions:
- AWS EMR vs. Redshift:
- Considered using Redshift for a data lake solution but opted for AWS EMR due to cost efficiency.
- EMR cluster extension to the core processing system, leveraging existing S3 data store.
- Low-cost solution achieved by using AWS EMR to realize the problem statement.
Business Impact of the New Reconciliation Solution Accuracy:
- Improved from three 9s to four 9s.
Speed:
- Reduced reconciliation time from 24 hours to a 15-minute cycle.
- Horizontal cluster ensures consistent processing time (max 30 minutes) regardless of transaction volume (1 million to 300 million transactions).
Risk Reduction:
- Faster reconciliation (within 15 minutes) minimizes potential fraud and risk.
- Allows for quicker action on system or external issues.
Cost Optimization:
- Chosen AWS EMR cluster over data lake solutions for cost efficiency.
- EMR cluster and Lambda functions operate on-demand, not continuously.
- Computing instances have a limited lifetime, freeing up resources and minimizing costs once processing is complete.
