Create Record in Custom Processor in Threads outside the process method

asked 2018-09-27 07:01:33 -0500

I have made a custom processor and when I get a record I start a thread to process this record. I am able to publish data to BatchMaker by invoking method batch.addRecord; however, I am not able to see this output in the output of the processor. What could be reason for this?

If I delay the termination of the process method using a Thread.sleep, I can get the output as long as the process method does not exit; however, this does not provide me with the next record for processing until the process method is complete, causing a delay in processing the data.

edit retag flag offensive close merge delete