相关疑难解决方法(0)

如何在特定偏移量到特定偏移量中使用来自 kafka 主题的数据?

我需要消耗特定的偏移量到特定的结束偏移量!!consumer.seek() 从特定偏移量读取数据,但我需要将数据从偏移量检索到 tooffset !!任何帮助将不胜感激,提前致谢。

    ConsumerRecords<String, String> records = consumer.poll(100);
    if(flag) {
        consumer.seek(new TopicPartition("topic-1", 0), 90);
        flag = false;
    }
Run Code Online (Sandbox Code Playgroud)

java apache-kafka kafka-consumer-api

5
推荐指数
1
解决办法
4328
查看次数

标签 统计

apache-kafka ×1

java ×1

kafka-consumer-api ×1