Best Practice Springs Kafka Consumer: какое сообщение должен получить потребительJAVA

Программисты JAVA общаются здесь
Anonymous
Best Practice Springs Kafka Consumer: какое сообщение должен получить потребитель

Сообщение Anonymous »

Мне нужно начать работать с Kafka. Мне трудно понять, что должен получить Потребитель:
Насколько я понимаю, мы можем настроить потребителя несколькими способами:
пример 1:

Код: Выделить всё

@KafkaListener(topics = "topic_name)
public void receiveSimpleString(@Payload String message) {
}
пример 2:

Код: Выделить всё

@KafkaListener(topics = "topic_name)
public void receiveConsumerRecord(@Payload ConsumerRecord 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 message) {
}
Может быть, есть еще другие способы, но когда-то я чаще всего видел именно их, исследуя kafka+spring.
Теперь вопрос:< /p>
Существует ли передовая практика относительно того, что должен получить потребитель?
Есть ли плюсы и минусы различных примеров?


Подробнее здесь: https://stackoverflow.com/questions/727 ... consumer-r

Вернуться в «JAVA»