java - 如何为 Kafka Streams 中多个实例的应用程序生成唯一的序列 ID？

Question

我想为我们从主题中使用的内容生成唯一的有序 ​​ID，并且它在多个实例中应该是唯一的。 (不是 uuid)

Answer 1

不知道为什么您不想使用 UUID。但是您可以使用偏移量和分区号的组合来计算唯一 ID。像这样的东西:

// you need to know upfront how many partitions the input topis has
private final static int NUMBER_OF_PARTITIONS = ...

// within `Transformer#transform()` using `KStream#transform()`
// (also consider to use #transformValues() instead).

// `context` is given via `init()`

long id = context.offset() * NUMBER_OF_PARTITIONS + context.partition();