I am using Akka Http with Kafka. For each incoming Request, i register a new actor with a unique UUID to Receptionist. This actor will be asked later for the response.
final String responseKey = UUID.randomUUID().toString(); final ServiceKey<Request> serviceKey = ServiceKey.create(Request.class, responseKey); context.getSystem().receptionist().tell(Receptionist.register(serviceKey, responseRef));
Kafka has two pipelines, 1 for requests and 2 for responses. Every message contains responseKey.
My question is: how can find the ServiceKey by using responseKey ?