Event Mapping & Business Flow Correlation

🔄

Kafka Event Sources Overview

AAServer:UserEndpoint - User interaction events

AAServer:AdminApi - Admin operations

AAServer:ConsentFlow - Consent management

AAServer:DataFlow - Data processing

AAServer:Notifications - System notifications

SMSProvider:SMSStatusService - SMS delivery tracking

🚀 Consent Request Events

aaRebitApiConsentRequest

FIU:AA:ConsentRequest → AA:FIU:ConsentRequestResponse

aaCustomApiConsentRequest

FIU:AA:ConsentRequestCustom → AA:FIU:ConsentRequestResponseCustom

aaConsentRequestEvent

AA:LOG:ConsentRequestEventMessage (internal logging)

2. User Authentication Stage

🔐 Authentication & OTP Events

aaUserEndpointConsetApi

USER:AA:WebsocketConsentApiRequest → AA:USER:WebsocketConsentApiResponse

aaUserEndpointWebApi

USER:AA:WebsocketWebApiRequest → AA:USER:WebsocketWebApiResponse

aaUserEndpointOtp

AA:SMS:OtpSMSRequest → SMS:AA:OtpSMSResponse

aaSmsStatusDlrPushApi

SMSProvider delivery status tracking

3. Account Discovery & Linking Stage

🔗 Account Discovery & Linking

aaUserEndpointDiscovery

AA:FIP:UserDiscoveryRequest → FIP:AA:UserDiscoveryResponse

aaUserEndpointLinking

AA:FIP:UserLinkingRequest → FIP:AA:UserLinkingResponse

aaUserEndpointConfirmLinking

AA:FIP:UserConfirmLinkingRequest → FIP:AA:UserConfirmLinkingResponse

aaRebitApiFIPLinkNotification

FIP:AA:AccountLinkNotificationRequest → AA:FIP:AccountLinkNotificationResponse

✅ Consent Approval Events

aaUserEndpointPostFIPConsent

AA:FIP:ConsentPostRequest → FIP:AA:ConsentPostResponse

aaUserEndpointFipConsentPostEvent

AA:LOG:ConsentPostEventRequest (internal logging)

aaUserEndpointFipConsentNotification

AA:FIP:ConsentNotificationRequest → FIP:AA:ConsentNotificationResponse

aaRebitApiFIPConsentNotification

FIP:AA:ConsentNotificationRequest → AA:FIP:ConsentNotificationResponse

📊 Status Tracking Events

aaRebitApiConsentStatus

FIU:AA:ConsentHandleStatusRequest → AA:FIU:ConsentHandleStatusResponse

aaRebitApiGetConsent

FIU:AA:ConsentFetchRequest → AA:FIU:ConsentFetchResponse

aaRebitApiFIPFIUConsentStatusNotification

AA:FIU:ConsentStatusNotificationRequest → FIU:AA:ConsentStatusNotificationResponse

Data Flow Events Mapping

FI Request Stage

📋 Financial Information Request

aaRebitApiFIRequest

FIU:AA:FIRequest → AA:FIU:FIRequestResponse | FIREQUEST_PROCESSOR

aaRebitApiFIPFIRequest

AA:FIP:FIRequest → FIP:AA:FIRequestResponse | FIREQUEST_PROCESSOR

aaFIRequestEvent

AA:LOG:FIRequestEvent (internal logging)

aaUserEndpointFIRequest

AA:AA:FIRequestForUser → AA:AA:FIResponseForUser | FIREQUEST_PROCESSOR

Data Fetch Stage

📥 Data Fetch Processing

aaRebitApiDataFetch

FIU:AA:FIFetchRequest → AA:FIU:FIFetchResponse | FIDATA_PROCESSOR

aaRebitApiFIPFIFetch

AA:FIP:FIFetchRequest → FIP:AA:FIFetchResponse | FIDATA_PROCESSOR

aaUserEndpointDataFetch

AA:AA:DataFetchRequestForUser → AA:AA:DataFetchResponseForUser | FIDATA_PROCESSOR

Notification Stage

🔔 Notification Events

aaRebitApiFIUNotification

AA:FIU:FINotificationRequest → FIU:AA:FINotificationResponse

aaRebitApiFIPFINotification

FIP:AA:FINotificationRequest → AA:FIP:FINotificationResponse

aaRebitApiFIPFIUFINotification

AA:FIU:FINotificationRequest → FIU:AA:FINotificationResponse

Special Processors & Funnel Events

⚙️ Special Processors

FIDATA_PROCESSOR

Handles financial data processing/transformation

FIREQUEST_PROCESSOR

Handles financial information request processing

🎯 Potential Funnel Events for DW

CONSENT_INITIATED:aaRebitApiConsentRequest | aaCustomApiConsentRequest

CONSENT_USER_AUTHENTICATED:aaUserEndpointConsetApi success

CONSENT_ACCOUNT_LINKED:aaUserEndpointConfirmLinking success

CONSENT_USER_APPROVED:aaUserEndpointPostFIPConsent success

CONSENT_FIP_APPROVED:aaRebitApiFIPConsentNotification with ACTIVE status

CONSENT_FULFILLED:aaRebitApiGetConsent success (ARTEFACT_READY)

DATA_FETCH_INITIATED:aaRebitApiFIRequest

DATA_FETCH_SUCCESSFUL:aaRebitApiDataFetch success

🔍 Missing Events Analysis

Need to verify if Kafka contains:

• User journey completion timestamps
• Error categorization events
• FIP-specific performance events
• Retry/failure tracking events
• User drop-off point events