KafkaListener headers 和有效负载顺序
KafkaListener headers and payloads order
这是我的代码,问题是 headers 在列表中的顺序和消息的顺序是否匹配?
@KafkaListener(
topics = ["topic"],
containerFactory = "kafkaBatchListenerContainerFactory",
)
fun receive(
@Payload messages: List<String?>,
@Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) keys: List<String>,
) {}
是; headers 列表中的索引与相应负载的索引相同。
这是我的代码,问题是 headers 在列表中的顺序和消息的顺序是否匹配?
@KafkaListener(
topics = ["topic"],
containerFactory = "kafkaBatchListenerContainerFactory",
)
fun receive(
@Payload messages: List<String?>,
@Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) keys: List<String>,
) {}
是; headers 列表中的索引与相应负载的索引相同。