ConsumerRecord 初始化

在使用 Kafka 消费者进行消息处理时，可以使用 `ConsumerRecord` 类来表示接收到的消息记录。`ConsumerRecord` 包含了关于消息的各种信息，如主题、分区、偏移量、键、值等。

以下是使用 `ConsumerRecord` 的初始化示例：

@KafkaListener(topics = "your-topic")
public void processMessage(ConsumerRecord<String, String> record) {
    // 获取消息的主题
    String topic = record.topic();
    
    // 获取消息的分区
    int partition = record.partition();
    
    // 获取消息的偏移量
    long offset = record.offset();
    
    // 获取消息的键
    String key = record.key();
    
    // 获取消息的值
    String value = record.value();
    
    // 对消息进行处理
    // ...
}

在上面的示例中，`processMessage` 方法接收一个 `ConsumerRecord` 对象作为参数，该对象表示从 Kafka 消费者接收到的消息记录。通过 `ConsumerRecord` 对象，您可以获取消息的主题、分区、偏移量、键和值等信息，并在方法中进行相应的处理。

请注意，上述示例中的键和值都被假设为字符串类型（`String`），您可以根据实际情况调整类型。

希望这可以帮助您初始化和使用 `ConsumerRecord` 对象。如果您有更多问题，请随时提问！