For each document, there are two line items and setting received flag on each line item as they are consumed from kafka topic.As these messages are coming at exact same time, second line item flag not setting, tried even adding synchronized on the method, which did not help.