Need an advice how to poll enrich from Kafka topic aggregating on content property

[Vyacheslav Boyko]

Hi!

I need to implement Request-Reply EIP on Kafka.

But aggregation strategy have to be done on content's property.

Simple example

from(QUEUE_PROCESS_FAST_RISK_SCORING)
        .setProperty(PROP_PAYMENT_DETAILS, body())
        .bean(self,"assembleKycRequest") // request contains one property 
"walletId"
        .marshal().json()
        .to(propertiesProvider.getKycRequestEndpoint()) // KAFKA REQUEST TOPIC
        .pollEnrich(propertiesProvider.getWalletKycResponseEndpoint(),// KAFKA 
RESPONSE TOPIC 30000,
            (oldExchange, newExchange) -> {
            return oldExchange;
            },false)

I need to aggregate response basing on property "walletId".

How do I deal with it?

--
Vyacheslav Boyko
mailto:mail4...@gmail.com