Anunay Anindya

Architected Event-Driven Microservices Platform: Led the design and implementation of reactive microservices for financial settlements using Spring Boot WebFlux with R2DBC for non-blocking database operations. Integrated Apache Kafka for event streaming and choreography-based saga patterns, achieving 3x throughput improvement with reduced latency. Reactive Systems Development: Developed high-performance async REST APIs using Spring WebFlux and Project Reactor, implementing backpressure handling and reactive streams. Built scheduled batch processors with reactive paradigms for asynchronous data fetch and persistence to SQL Server with R2DBC drivers. Big Data & Stream Processing: Migrated Data Science workflows from Scala/Spark to Python/PySpark for better maintainability. Enhanced ETL pipelines using Kafka Streams and Apache Spark on Hadoop edge servers. Architected real-time data processing with Kafka Connect and Debezium for CDC (Change Data Capture) from MySQL to event streams. Distributed Database Architecture: Designed and implemented active-active MySQL master-master replication for high availability. Configured multi-region database synchronization with conflict resolution strategies. Managed schema versioning with Liquibase across distributed environments (dev, test, prod). Cloud-Native Platform Engineering: Led monolithic-to-microservices migration on AWS EKS with Kubernetes orchestration. Implemented service mesh patterns, Helm chart deployments, and GitOps workflows. Configured API Gateway with routing policies, rate limiting, and circuit breakers using Terraform IaC. GraphQL API Architecture: Designed and developed GraphQL facade service with Spring Boot Java 17 for unified API layer. Implemented efficient schema design for queries, mutations, and subscriptions with DataLoader pattern for N+1 query optimization. Distributed Observability & SRE: Built comprehensive observability stack with Grafana dashboards sourcing metrics from Splunk, Cloudwatch, and Prometheus. Implemented distributed tracing with correlation IDs. Configured Terraform-managed alerting for latency, throughput, error rates, and SLO violations. Container Orchestration & Auto-Scaling: Implemented Horizontal Pod Autoscaler (HPA) with custom metrics for dynamic scaling. Tuned JVM parameters, connection pools, and resource limits for optimal performance under load. Achieved 99.9% uptime with zero-downtime deployments. Data Pipeline & Analytics: Architected serverless ETL data pipeline integrating multiple sources (MySQL, Kafka events, S3) with sink to Snowflake data warehouse. Built AWS Lambda functions in Python for data transformation. Integrated with downstream analytics platforms. CI/CD & GitOps Automation: Established GitHub Actions pipelines for automated builds, integration tests, security scans, Docker image publishing to GHCR, and progressive deployment to Kubernetes. Implemented blue-green and canary deployment strategies with automated rollback. Security & Compliance: Implemented JWT-based authentication with Okta IdP integration. Built RBAC authorization framework in microservices. Configured Azure Entra App ID certificates for service-to-service authentication. Ensured PCI-DSS compliance for payment processing systems. Built React based UI components for data management with Nx and Vite monorepo setup and shadcn UI components with accessibility for Visa Design Platform.

Event-Driven Microservices Architecture: Re-engineered monolithic legacy system into distributed microservices using event-driven patterns with Apache Kafka for event streaming and async communication. Implemented event sourcing and CQRS patterns for data consistency across services. Reactive API Development: Built high-performance facade microservices using Java 17 and Dropwizard framework with reactive HTTP clients (OkHttp3, Retrofit). Implemented dependency injection with Dagger2 for maintainable architecture. Designed RESTful APIs with circuit breakers and retry mechanisms for resilience. Developed a micro frontend in React 16 and hooked it back to legacy GWT. Serverless & Cloud-Native Solutions: Architected serverless computing platform on AWS using Lambda functions for compute, API Gateway for routing, and event-driven triggers from S3, DynamoDB Streams, and SNS/SQS. Deployed containerized services to AWS EKS with auto-scaling groups. Distributed Data Architecture: Designed multi-tier caching strategy with Redis for sub-millisecond latency and DynamoDB as primary NoSQL data store. Implemented cache invalidation patterns and distributed locking mechanisms. Performed data migration scripts in Python for database transitions. GraphQL API Gateway: Developed unified GraphQL API layer for mobile and backend clients, implementing efficient resolvers, DataLoader batching, and subscription support via WebSockets. Reduced over-fetching and improved API efficiency by 40%. Big Data & Stream Processing: Enhanced Apache Spark and Scala jobs for processing video metadata and analytics. Implemented Kafka topic partitioning strategies for high-throughput analytics data streaming to downstream systems. Built real-time data pipelines for social media engagement metrics. Cloud Storage & Media Processing: Architected scalable video storage solution on AWS S3 with lifecycle policies and CloudFront CDN distribution. Implemented webhook-based integrations with YouTube API for asynchronous playlist management and video ingestion. Container Orchestration: Established Docker and Docker Compose based local development environments mirroring production. Deployed services to Kubernetes clusters with service discovery, load balancing, and health checks. Implemented blue-green deployment strategies. Observability & Monitoring: Integrated distributed logging and monitoring using Amazon CloudWatch, Sumologic (ELK stack), and custom metrics. Set up alerting pipelines to Slack channels for incident management and on-call response. Authentication & Security: Implemented OAuth 2.0 flows with OneLogin as IdP and JWT token-based authentication. Built secure inter-service communication with mTLS and API key management. Integration Patterns: Connected microservices to Salesforce SFDX apps via serverless Lambda functions, implementing async messaging patterns and retry logic for third-party API integrations.

Development of a configurable multi tenant product, using React, enterprise Ag-Grid for server side row modeling, unit test using Jest and integration test using Cypress, automation and e2e using cucumber and wdio(selenium). Event-Driven Multi-Tenant Platform: Architected scalable multi-tenant SaaS platform for advertisement e-commerce using microservices architecture with Spring Boot and Java 8. Implemented tenant isolation at database and application layers with dynamic routing. CQRS & Event Sourcing: Designed and implemented CQRS (Command Query Responsibility Segregation) pattern with Elasticsearch as read model for high-performance queries and analytics. Achieved 10x improvement in query performance for complex aggregations. Change Data Capture (CDC) Pipeline: Built real-time data synchronization using Debezium Kafka Connect with MongoDB as source and Elasticsearch as sink. Implemented event-driven data replication for near-zero latency between write and read models, ensuring eventual consistency. RESTful API Architecture: Developed enterprise-grade REST APIs with Spring Boot implementing pagination, filtering, sorting, and server-side data processing for large datasets. Built multi-tenant aware API layer with tenant context propagation. Testing & Quality: Established comprehensive testing strategy with unit tests, integration tests using Testcontainers for Kafka and databases, and contract testing for microservices communication. Achieved 85%+ code coverage.

Created a facade microservice in Kotlin and Spring Boot, with exception handling using Spring AOP, integration to legacy service using Spring Integration, integration to other microservices using Spring REST template, contract implementation to upstream services using Spring Cloud Contract and Pact as provider, cache implementation using Caffeine, service discovery and token directory using Hashicorp Consul and Vault. Event sourcing implementation using AXON framework in the core microservice. Container orchestration using Docker Swarm. API management using APIGEE - proxying, gateway, ssl, authentication, masking. Performed REST api development using Spring boot, Spring AOP, Javax validation, Kotlin, AXON, Postgresql, CICD using Docker, Kubernetes, Spring Cloud. Microfrontend UI Development using Preact. Worked on the Development of a rest api space optimiser on microservices architecture following agile methodology. Data Modeling in Cassandra and document store in Couchbase, REST API development using Java 8, Spring boot. Data visualization using Flask, Python, Plotly, Celery. Designed strategic plans for component development practices to support future projects. Implemented REST API with Spring, Spring Boot, Spring AOP, Spring Data. Widget development using Flask web components, consuming data from data science jobs using Celery and graphical representation using Plotly and data exploration using Python. Worked as Senior Consultant Corporate Banking Domain. Development of a flagship product guarantee system on microservices architecture following agile methodology. Web app development using React, Typescript, REST api development using Java 8 and spring boot, docker and integrating and orchestrating Microservices using Spring Integration, batch processing using Spring Batch, BDD using cucumber.

Performed Web application Development and Maintenance global lineup and sorting, using Jquery, Java, JSF, spring webflow, Spring boot, sql server. Managed the end-to-end software project development life cycle.

Performed Web application maintenance using java, icefaces, cobol, jcl, db2.