Зачем использовать шаблон SpringKafka вместо существующих API-интерфейсов Kafka Producer?

Question

Какие преимущества предоставляет шаблон Spring Kafka?

Я попробовал существующий API производителя / потребителя от Kafka.Это очень просто использовать, тогда зачем использовать шаблон Kafka.

Answer 1

На высоком уровне преимущество состоит в том, что вы можете легче выводить объекты свойств и просто сосредоточиться на логике обработки записей.

Plus Spring интегрирован со множеством других компонентов.

Примечание: по-прежнему существуют другие опции, такие как Reactor Kafka, Alpakka, Apache Camel, Smallrye реагирующий обмен сообщениями, Vert.x ... Но все они используют один и тот же API-интерфейс Kafka.

Итак, яскажу, что вы (незначительно) торгуете ради удобства

Answer 2

Шаблон Kafka внутренне использует производителя Kafka, поэтому вы можете напрямую использовать API-интерфейсы Kafka.Преимущество использования шаблона Kafka состоит в том, что он предоставляет различные методы для отправки сообщений в тему Kafka, некоторые дополнительные преимущества вы можете увидеть в сравнении API между KafkaProducer и KafkaTemplate здесь:

https://kafka.apache.org/10/javadoc/org/apache/kafka/clients/producer/KafkaProducer.htmlhttps://docs.spring.io/spring-kafka/api/org/springframework/kafka/core/KafkaTemplate.html

Можно видеть, что KafkaTemplate предоставляет много дополнительных способов отправки данных в темы Kafka из-за различных методов send, в то время как некоторые вызовы такие же, как в Kafka API, и просто перенаправляются из KafkaTemplate вKafkaProducer.

Это зависит от разработчика, что использовать.Если вам кажется, что работать с KafkaTemplate легко, поскольку вам не нужно создавать ProducerRecord, простой метод send сделает всю работу за вас.