如何使用 spring boot 在 kafka 中将文件从生产者发送到消费者?

How to send a file from producer to consumer in kafka using spring boot?

我有一个 kafka 程序可以从生产者发送一条消息,它由消费者使用 successfully.But 我有一个问题,有什么方法可以发送文件而不是一条文本消息..如果是怎么办?

你可以在 Kafka 中发送你想要的任何内容。 Kafka 不会从你的数据中推断出任何东西,它会将它作为一个简单的字节数组来处理。但是要注意你的 Kafka 记录的大小,一些集群参数,如 message.max.bytes (以及许多其他)必须相应地更新。

所以要回答您的问题,只需使用任何类型的 IO reader(取决于您的编程语言)读取您的文件,然后使用字节或字符串序列化程序发送您的文件。

雅尼克