Использование#

Для работы Corax использует два класса:

KafkaProducer — клиент, публикующий записи в кластере Corax (производитель);
KafkaConsumer — клиент, читающий записи в кластере Corax (потребитель).

См. также

Так же при разработке можно воспользоваться ИИ-ассистентом для поиска информации по документации, подробнее в разделе «ИИ-ассистент по документации».

KafkaProducer#

Функцией KafkaProducer является публикация записей в кластере Corax.

Класс KafkaProducer отсылает один экземпляр производителя по всем потокам; это позволяет значительно повысить быстродействие по сравнению с отправкой отдельных экземпляров для каждого потока.

KafkaConsumer#

Класс KafkaConsumer — это клиент, который принимает записи из кластера Corax.

Этот клиент прозрачно обрабатывает сбои брокеров Corax и прозрачно адаптируется по мере миграции разделов топиков в пределах кластера. Он также взаимодействует с брокерами таким образом, чтобы группы потребителей могли балансировать нагрузку с помощью группировки потребителей.

Потребитель поддерживает TCP-соединения с необходимыми брокерами для получения данных. Если не закрыть соединение после того, как потребитель закончил его использовать, то произойдет утечка этого соединения.

Внимание

Потребитель не имеет средств безопасности для потоков.

Совместимость версий#

Клиент может взаимодействовать с брокерами, у которых версия ядра 0.10.0 или выше. Более старые или более новые брокеры могут не поддерживать определенные функции. Например, брокеры с версией ядра 0.10.0 не поддерживают функцию offsetsForTimes, поскольку она была добавлена в версии ядра 0.10.1. При вызове API, недоступного в запущенной версии брокера, появится исключение UnsupportedVersionException.