API do processador Kafka: chave diferente para Source e StateStore?

No momento, estamos implementando um processo (usando a API do processador Kafka) onde precisamos combinar informações de 2 eventos correlatos (mensagens) sobre um tópico e encaminhar essas informações combinadas. Os eventos são originários de dispositivos IoT e, como queremos mantê-los em ordem, o tópico de origem usa um identificador de dispositivo como chave. Os eventos também contêm um ID de correlação:

Chave

{ deviceId: "..." }

mensagem

{ deviceId: "...", correlationId: "...", data: ...}

Nossa primeira abordagem foi criar um processador que possui um armazenamento de estado conectado, que armazena todas as mensagens recebidas, usando o ID de correlação como chave. Isso nos permite consultar a loja pelo ID de correlação de uma mensagem recebida e, se já houver uma mensagem com o mesmo ID na loja, podemos combinar as informações, encaminhar um novo evento e remover a entrada da loja. Portanto, para cada ID de correlação, acontece o seguinte: em algum momento, a primeira mensagem com esse ID é consumida e armazenada e, em outro momento, a segunda mensagem com esse ID resulta na remoção da entrada da loja.

Chave de estado

{ correlationId: "..." }

Valor do Estado

{ event: { deviceId: "...", correlationId: "...", data: ... }}

Mas agora estamos nos perguntando como o Kafka Streams está lidando com as diferentes chaves. Estamos usando uma abordagem de microsserviço e haverá várias instâncias desse serviço em execução. A loja é apoiada automaticamente por um tópico interno. Considere redimensionar as instâncias de serviço, s.t. as partições do tópico de origem e do tópico de estado são reequilibradas. É possível que a partição para um ID de correlação específico seja atribuída a outro serviço que não seja a partição para o ID do dispositivo correspondente? Poderíamos terminar em uma situação se o segundo evento com o mesmo ID de correlação fosse consumido por uma instância de serviço, que não tem acesso ao primeiro evento já armazenado?

Desde já, obrigado!