[大数据]kafka消费指定offset消息

public static void main(String[] args) {
        Properties props = new Properties();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "");
        props.put(ConsumerConfig.GROUP_ID_CONFIG, "");
        props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
        props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false");
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class);
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class);
        KafkaConsumer<JsonNode, JsonNode> consumer = new KafkaConsumer<>(props);
        TopicPartition topicPartition = new TopicPartition("topic", 9);
        consumer.assign(Collections.singletonList(topicPartition));
        consumer.seek(topicPartition, 675);
        while (true) {
            ConsumerRecords<JsonNode, JsonNode> records = consumer.poll(Duration.ofMillis(10000));
            for (ConsumerRecord<JsonNode, JsonNode> record : records) {

            }
            consumer.commitSync();
        }
    }