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

[Vyacheslav Boyko <ma...@gmail.com>]

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:mail4bvn@gmail.com