Насколько я понимаю, мы можем настроить потребителя несколькими способами:
пример 1:
Код: Выделить всё
@KafkaListener(topics = "topic_name)
public void receiveSimpleString(@Payload String message) {
}
Код: Выделить всё
@KafkaListener(topics = "topic_name)
public void receiveConsumerRecord(@Payload ConsumerRecord message) {
}
Код: Выделить всё
@KafkaListener(topics = "topic_name)
public void receiveObject(@Payload SomeCustomClass message) {
}
Код: Выделить всё
@KafkaListener(topics = "topic_name)
public void receiveSpringMessage(@Payload org.springframework.messaging.Message message) {
}
Теперь вопрос:< /p>
Существует ли передовая практика относительно того, что должен получить потребитель?
Есть ли плюсы и минусы различных примеров?
Подробнее здесь: https://stackoverflow.com/questions/727 ... consumer-r