Java 如何在 Spring Integration Kafka 消息中设置 ID 标头

KafkaMessageDrivenChannelAdapter有一个选项:

/**
 * Set the message converter to use with a record-based consumer.
 * @param messageConverter the converter.
 */
public void setRecordMessageConverter(RecordMessageConverter messageConverter) {

其中，您可以通过以下方式设置MessagingMessageConverter:

/**
 * Generate {@link Message} {@code ids} for produced messages. If set to {@code false},
 * will try to use a default value. By default set to {@code false}.
 * @param generateMessageId true if a message id should be generated
 */
public void setGenerateMessageId(boolean generateMessageId) {
    this.generateMessageId = generateMessageId;
}

/**
 * Generate {@code timestamp} for produced messages. If set to {@code false}, -1 is
 * used instead. By default set to {@code false}.
 * @param generateTimestamp true if a timestamp should be generated
 */
public void setGenerateTimestamp(boolean generateTimestamp) {
    this.generateTimestamp = generateTimestamp;
}

设置为true.

这样，从ConsumerRecord创建的Message将具有各自的id和timestamp报头.

您还可以简单地使用一个"虚拟"转换器来返回传入的有效负载，框架将在其中创建一个新的Message来生成这些标头.