我每天都会生成数千个文件,我希望使用Kafka进行流式传输.当我尝试读取文件时,每一行都被视为单独的消息.
我想知道如何在Kafka主题中将每个文件的内容作为单个消息进行处理,并且消费者如何在单独的文件中将Kafka主题中的每个消息写入.
apache-kafka kafka-consumer-api kafka-producer-api
apache-kafka ×1
kafka-consumer-api ×1
kafka-producer-api ×1