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

Question

我需要开始使用 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 时最常看到的。

现在的问题是:

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

Answer 1

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

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