apache-kafka - 卡夫卡 : explicitly assign a non-zero initial offset at topic creation

Question

在创建新的 kafka-topic 时，有没有办法将其所有分区的最小偏移量设置为大于 0 的值？如果没有直接的方法，是否有直接操纵kafka-internal offsets的间接方法？

换个问法，函数createTopic("foo", 4, 1000)实现创建一个名为“foo”的新主题，由 4 个分区组成，其中每个分区产生的第一条消息将获得偏移 1000(而不是 0)，第二个 1001，依此类推......

Answer 1

Afaik 没有办法做到这一点，但问题是你想用它来实现什么？
我猜您正在尝试将偏移量用作消息的一种唯一标识符，是吗？为什么不使用 key 呢？