如何使用 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(取决于您的编程语言)读取您的文件,然后使用字节或字符串序列化程序发送您的文件。
雅尼克
我有一个 kafka 程序可以从生产者发送一条消息,它由消费者使用 successfully.But 我有一个问题,有什么方法可以发送文件而不是一条文本消息..如果是怎么办?
你可以在 Kafka 中发送你想要的任何内容。 Kafka 不会从你的数据中推断出任何东西,它会将它作为一个简单的字节数组来处理。但是要注意你的 Kafka 记录的大小,一些集群参数,如 message.max.bytes (以及许多其他)必须相应地更新。
所以要回答您的问题,只需使用任何类型的 IO reader(取决于您的编程语言)读取您的文件,然后使用字节或字符串序列化程序发送您的文件。
雅尼克