Kafka ProducerRecord 本身是不可变的。一旦创建了一个 ProducerRecord 对象,它的属性(如 key、value、topic 等)就不能被修改。如果你需要创建一个具有不同属性的 ProducerRecord 对象,你需要创建一个新的对象,而不是修改现有的对象。
但是,你可以通过创建一个新的 ProducerRecord 对象并设置不同的属性值来实现类似的功能。例如,如果你有一个已创建的 ProducerRecord 对象,你可以这样做:
ProducerRecord<String, String> originalRecord = new ProducerRecord<>("my-topic", "key", "value"); // 创建一个新的 ProducerRecord 对象,设置不同的属性值 ProducerRecord<String, String> newRecord = new ProducerRecord<>("my-topic", "newKey", "newValue"); 请注意,Kafka ProducerRecord 的不可变性有助于确保在生产者和消费者之间的数据一致性。