datapipe build using spark structured streaming and kafka and persisting data into PostgreSQL database
-
Updated
Aug 15, 2019 - Scala
datapipe build using spark structured streaming and kafka and persisting data into PostgreSQL database
AI-powered relationship CRM built as 4 Spring Boot microservices with Kafka-async AI enrichment. AWS Bedrock + FAISS semantic dedup improves contact-matching accuracy by 70%; a transparent 0-100 relationship-health score updates in under 200ms, and Claude (200K-token context) answers natural-language CRM queries in 2-5 seconds.
A lightweight mediator and messaging library for .NET - send commands, publish event and execute queries through middleware pipelines, with many transports
To associate your repository with the kafk topic, visit your repo's landing page and select "manage topics."