Kafka 2.1.0 Java Consumer против Scala Consumer

Question

Я бы хотел обновить кластеры Kafka моей команды с версии 0.10.1.1 до версии 2.1.0. Кстати, в официальном документе Кафки говорится следующее:

Кафка Официальный Документ

Обратите внимание, что более старые клиенты Scala, которые больше не поддерживаются, не поддерживают формат сообщений, введенный в 0.11, поэтому, чтобы избежать затрат на конвертацию (или воспользоваться преимуществом единовременной семантики), необходимо использовать более новые клиенты Java.

Я плохо понимаю это предложение. В настоящее время наша команда использует приложение Kafka Consumer, написанное на Scala. Но мы должны превратить это в Java? Если в настоящее время мы используем приложение, написанное на Scala, я не знаю точно, какие у него могут быть недостатки.

Answer 1

Я думаю, вы путаете старые основанные на Scala пакеты kafka.consumer и kafka.producer, которые были в основном модуле Kafka, с новой зависимостью kafka-clients, реализованной в Java.

Если вы импортируете эти файлы, у вас все будет хорошо, и вам не нужно будет использовать другие классы, и вам может понадобиться только переписать несколько параметров вызовов методов после обновления

org.apache.kafka.clients.consumer.KafkaConsumer
org.apache.kafka.clients.producer.KafkaProducer

мы должны превратить это в Java? Если в настоящее время мы используем приложение, написанное на Scala, я не знаю точно, какие у него могут быть недостатки

Java более многословен и не имеет такой хорошей системы типов, как Scala. Вы можете написать один и тот же код на Scala, Kotlin, Clojure и т. Д ... В конце концов, все это работает в JVM