Remote partitioning with replies issue using Kafka

[AbhiramYay]

I am enhancing our spring batch job to use remote partitioning with Kafka.

When we are running multiple jvms of batch component,
the worker replies not being sent to master step jvm where it aggregates the replies.

As the Manager reply Kafka listener is enabled in multiple jvms, the reply Kafka message consumed by any jvm. My manager step not completing due to this issue.

How we can resolve this.

[quaff]

Two solutions:

1. don't use reply, then manager step will poll results

   spring-batch/spring-batch-integration/src/main/java/org/springframework/batch/integration/partition/MessageChannelPartitionHandler.java

   Lines 225 to 230 in d8632a3

   	if (!pollRepositoryForResults) {
   	return receiveReplies(replyChannel);
   	}
   	else {
   	return pollReplies(managerStepExecution, partitionStepExecutions);
   	}

2. separate Manager and Worker deployment, don't run manager on multiple JVMs.

I recommend option 1.