返回到文章

采纳

编辑于

kafka如果修改偏移量

kafka

大神,您好,kafka偏移量保存zookeeper和kafka,zookeeper中可通过命名修改偏移量,kafka中如何修改偏移量?consumer.seek(new TopicPartition(topic, partition), offset);好像并没有起作用