问Kafka:在创建topic时显式分配非零的初始偏移量
EN

Stack Overflow用户

提问于 2017-12-15 04:35:50

回答 1查看 450关注 0票数 3

新建kafka-topic时，有没有办法将所有分区的最小偏移量设置为大于0的值？如果没有直接的方法，是否有可能通过直接操作kafka内部偏移量的间接方法？

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

发布于 2017-12-15 14:41:29

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

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/47821606

复制

相似问题

问Kafka:在创建topic时显式分配非零的初始偏移量EN