我有一个有点奇怪的用例，我们的应用程序没有使用标准的Kafka分区。相反，我们有一个自定义的分区策略，我们使用复合键中的特定字段来决定如何分区。这通常是CustomerId，以便单个客户的所有记录都包含在单个分区中，但是键还包含使消息唯一的其他Id，以便压缩仍然有效。
例如
主题-1-键

{
  orderId,
  customerId
}

主题2键

{
  addressId,
  customerId
}

我想将这两条记录连接在一起，为了使用DSL实现这一点，我唯一的选择是将两条记录的密钥更新为客户ID，然后进行连接。然而，当我这样做时，Kafka-streams会自动决定发生了密钥更改操作，并为我创建重新分区主题。在使用DSL时，有没有什么方法可以覆盖这种行为？
我知道我可以使用处理器API和状态存储手动完成此操作，但我想知道是否有一种方法可以使用DSL完成此操作，或者这不是一种选择。