Как отправить список объектов в тему кафки с помощью фреймворка spring-kafka? - PullRequest
0 голосов
/ 20 июня 2019

Я использую spring-kafka в приложении spring-boot для отправки темы данных.Мне нужно получить данные из таблицы оракула и отправить их.

Я получаю список из таблицы оракула.Как отправить их в тему?

т.е.

  1. Есть ли способ отправить их в виде списка?если да как?Если да, то как его десериализовать на стороне потребителя?

  2. Можно ли отправлять данные в потоковом режиме, используя spring-book и spring-kafka?если да, больше информации или образца / фрагмента, плз ...

Как обрабатывать partitionKey, если я отправляю список за один раз?

В настоящее времяЯ отправляю отдельную компанию, следовательно, ключ определен, как показано ниже

companyKafkaTemplate.send(COMPANY_TOPIC,this.getKey(company), company);

1 Ответ

1 голос
/ 20 июня 2019

Для сериализации и десериализации List я бы предложил использовать поддержку JSON в Spring Kafka: https://docs.spring.io/spring-kafka/docs/2.2.7.RELEASE/reference/html/#serdes

Для потоковой передачи Я бы предложил взглянутьв поддержку Reactive в Spring Kafka, основанную на проекте Reactor Kafka: https://github.com/reactor/reactor-kafka

Для этой цели мы предоставляем ReactiveKafkaProducerTemplate и ReactiveKafkaConsumerTemplate.

...