I'm using the ListenTCPRecord processor to receive XML data that is streamed over TCP. I setup the XMLReader as the Record Reader and specified an avro xchema to represent my XML data.
When I send an XML record over TCP I always see a delay of 5 seconds before it passes thedata to the next processor. The debug logs show it "Re-queuing connection for further processing."
I would have expected that since I specified my schema it knows that the XML record has been received and it should pass it to the next processor without this delay.
11:27:28 EST DEBUG 01661012-6e35-1740-54a5-0d38ca3252de ListenTCPRecord[id=01661012-6e35-1740-54a5-0d38ca3252de] Accepted connection from /XXX.XXX.XXX.XXX:47584
11:27:33 EST DEBUG 01661012-6e35-1740-54a5-0d38ca3252de ListenTCPRecord[id=01661012-6e35-1740-54a5-0d38ca3252de] Re-queuing connection for further processing..