gpt4 book ai didi

java - 最佳实践 Springs Kafka Consumer : What kind of message should the consumer receive

转载 作者:行者123 更新时间:2023-12-01 22:57:05 27 4
gpt4 key购买 nike

我需要开始使用 kafka。我很难理解消费者应该收到什么:据我了解,我们可以通过多种方式配置消费者:

示例 1:

@KafkaListener(topics = "topic_name)
public void receiveSimpleString(@Payload String message) {
}

示例 2:

@KafkaListener(topics = "topic_name)
public void receiveConsumerRecord(@Payload ConsumerRecord<String, String> message) {
}

示例 3:

@KafkaListener(topics = "topic_name)
public void receiveObject(@Payload SomeCustomClass message) {
}

示例 4:

@KafkaListener(topics = "topic_name)
public void receiveSpringMessage(@Payload org.springframework.messaging.Message<T> message) {
}

也许还有更多的方法,但那些曾经是我在研究 kafka+spring 时最常看到的。

现在的问题是:

是否有关于消费者应该收到什么的最佳实践?不同示例有优缺点吗?

最佳答案

对此没有黄金法则,这完全取决于您的具体用例。有些人,包括我自己,更喜欢通过 ConsumerRecord 实例接收数据。这样,您不仅可以访问实际有效负载,还可以访问它附带的整个元数据。

您可能值得研究一下 Kafka Streams API .由于 exactly once delivery,这通常是从 Kafka 消费和生产到 Kafka 时使用的模式。

关于java - 最佳实践 Springs Kafka Consumer : What kind of message should the consumer receive,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/72777983/

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com