如何使用spring kafka框架将对象列表发送到kafka主题？

Question

我在sping-boot应用程序中使用sping-kafka发送数据主题。我需要从oracle表中获取数据并发送它。

我从oracle表中获取列表。如何将它们发送到主题？

即。

>

有没有办法将它们作为列表发送？如果是，如何发送？如果是，那么如何在消费者端反序列化它？

是否可以使用spring book和spring kafka以流式方式发送数据？如果是，请提供更多信息或样本/片段plz。。。

如果我一次发送列表，如何处理partitionKey？

目前我正在发送个人公司obj，因此密钥定义如下

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

Answer 1

对于序列化和反序列化，我建议在Spring Kafka中使用JSON支持：https://docs.spring.io/spring-kafka/docs/2.2.7.RELEASE/reference/html/#serdes

对于流媒体，我建议以ReactorKafka项目为基础，研究Spring Kafka中的反应式支持：https://github.com/reactor/reactor-kafka

为此，我们提供了一个ReactiveKafkaProducerTemboard和ReactiveKafka消费者模板。