WEB Development Required Resources

Jira PRGCRMHUB-1782: [SendService] Multi-threaded Kafka consumption Description / Purpose Improved SendService Kafka message processing by introducing asynchronous, multi-threaded execution to handle communications faster, especially time-sensitive messages such as OTPs. Changes Implemented Thread Pool: Added a dedicated ThreadPoolTaskExecutor with core size 8, max size 16, and queue capacity 50. Async Processing: Used CompletableFuture to process Kafka messages using worker threads. Acknowledgment Handling: Added manual acknowledgment handling and a separate Kafka listener factory for SendService to avoid impacting DataService. Exception Handling: Improved error logging and asynchronous failure propagation. MDC Tracing: Added MDC context propagation and restoration across threads. Existing Logic: Preserved current message validation, expiry handling, and SFMC processing behavior. Testing Maven build successful; 13 targeted tests passed. Verified success, failure, acknowledgmen...

1. हिंदी में समझिए — Kafka Streams migration में अलग से batching क्यों implement करनी पड़ी? भाई, आपका reason technically सही है। लेकिन manager को explain करते समय एक important distinction रखना है: आपने batching कोई नई business functionality जोड़ने के लिए implement नहीं की थी। आपने existing @KafkaListener का batch-processing behavior Kafka Streams migration के बाद भी बनाए रखने के लिए implement की थी। पहले @KafkaListener में क्या हो रहा था? Spring Kafka में batching का support पहले से available था। हमारे existing implementation में: Kafka consumer एक poll में multiple records fetch कर सकता था। Spring Kafka का batch listener उन records को List<ConsumerRecord<String, String>> के रूप में method को देता था। max.poll.records और batch listener configuration से यह behavior control होता था। हमारा existing Data Service consumer पूरी list को एक साथ process करता था। इसलिए हमें manually records collect करने की जरूरत नहीं थी। Kafka Streams में migrate करने के बाद क्या बदला? Kafka Stre...

  Challenging work i have done in my previous project ✅ 1️⃣ One-minute interview explanation (you can speak this) “We were reading millions of records from one system and inserting them into another database. Initially, we faced performance issues and OutOfMemoryError because the entire data was loaded into memory. To solve this, I implemented batch processing with multithreading. I processed records in chunks of 1000, performed transformation, inserted them into the database, cleared memory, and then processed the next batch. This made the system memory-efficient and scalable public void processLargeData(List<String> records) {         for (int i = 0; i < records.size(); i += BATCH_SIZE) {             int end = Math.min(i + BATCH_SIZE, records.size());             List<String> batch = records.subList(i, end);...

import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.mockito.Mockito; import org.springframework.batch.core.Step; import org.springframework.batch.core.job.builder.StepBuilder; import org.springframework.batch.core.repository.JobRepository; import org.springframework.batch.core.step.builder.StepBuilderHelper; import org.springframework.batch.repeat.RepeatStatus; import org.springframework.transaction.PlatformTransactionManager; import static org.junit.jupiter.api.Assertions.*; import static org.mockito.Mockito.*; public class MyJobConfigurationTest {     private MyJobConfiguration myJobConfiguration;     private FileBackUpTasklet fileBackUpTasklet;     private JobCompletionListener jobCompletionListener;     private JobRepository jobRepository;     private PlatformTransactionManager transactionManager;     @BeforeEach     public void setUp() {         fileBackUpTas...

  git config user.name " irfankhansoft" git config user.email "irfankhansoftwareengineer@gmail.com" git config --list Create Repository inside your Github and copy that url Now add the remote repo using this url git remote add origin https://github.com/irfankhansoft/git-localconfig-repo git push origin master while push it might ask to authorised by browser just login with your credential to login

 Thread Termination: Why : Because Thread are Consuming Resources : Like Memory, Kernel Recourses, cpu Cycle and cache memory When: 1. if thread finished its work, so we need to clean up the thread's resources 2. if thread misbehaving  3. By default application will not stope the thread as long as at least one thread is still running  Therad.intrrupt(): 1 if the thread is executing a method that throws an intrrupedException 2. if the thread's code is handling the interrupt signal explicitly  3.  If any one of the thread is in sleeping or waiting state (i.e. sleep() or wait() is invoked), calling the Thread.interrupt() method on the thread, breaks out the sleeping or waiting state throwing InterruptedException. If the thread is not in the sleeping or waiting state, calling the interrupt() method performs normal behavior and doesn't interrupt the thread but sets the interrupt flag to true   Daemon Thread: Daemon threads are thread that do not prevent the...

How to Create Thread There are two ways to Create Thread  1 Extending Thread Class public class ThreadClass extends Thread { @Override public void run() { System . out .println( "Thread Running Thread " +Thread. currentThread ().getName()); } } 2. Runnable Interface public class RunnableClass implements Runnable { @Override public void run() { System. out .println( "Runnable Running Thread " +Thread. currentThread ().getName()); } } Main Class how to Call the Thread and Runnable Threads public class Main { public static void main(String[] args ) { ThreadClass tClass = new ThreadClass(); tClass .start(); RunnableClass rClass = new RunnableClass(); Thread rThread = new Thread( rClass ); rThread .start(); } }    Both will Create the Similar Thread but there are some Advantages as Runnable Interface are 1.  Less memory required for Runnable Interface 2.  If a class is implementing the runnable interface then ...