GH-3057: ReactiveKafkaConsumerTemplate missing receiveBatch method

[marcusvoltolim]

• Adding wrapper method receiveBatch in ReactiveKafkaConsumerTemplate.

Closes #3057

[sobychacko]

@marcusvoltolim Why are you changing the batch semantics in the API? The batchReceives has a return of Flux<Flux<ReceiverRecord<K, V>>> and you are flat mapping it. Why can't we let the user make that decision?

[marcusvoltolim]

@marcusvoltolim Why are you changing the batch semantics in the API? The batchReceives has a return of Flux<Flux<ReceiverRecord<K, V>>> and you are flat mapping it. Why can't we let the user make that decision?

I used receiveAutoAck as an example, which does the same thing.

[sobychacko]

Thanks. But, since we are explicitly dealing with a batch API here, producing the output in the raw format might be beneficial without that flatmap operation.

[marcusvoltolim]

Thanks. But, since we are explicitly dealing with a batch API here, producing the output in the raw format might be beneficial without that flatmap operation.

I agree, and removed the concatMap operation.

[sobychacko]

Any chance you can verify the new API via a unit or integration test?

[marcusvoltolim]

Any chance you can verify the new API via a unit or integration test?

I will try make this test!

[sobychacko]

@marcusvoltolim Any updates? We have a release next week, and if you want this to be part of that release, then this needs to be addressed sooner so we can progress on the PR.

[sobychacko]

@marcusvoltolim We merged the PR to include this in the 3.2.0-M2 release. Feel free to work on any testing aspects of this change in a separate PR. Thanks for your PR contribution.