我要求在哪里记录主题。用单条记录,我创建了n个不同的作业(应分发)。成功处理n个作业后,我需要推送成功处理的记录。它是否符合Kafka视频流的条件?基本上我正在看的是,我有需要转码的视频(可以说持续20分钟)。我将创建4个任务(每个5分钟),每个工作人员将分别处理这4个任务。完成所有4个任务后,我需要将其缝合在一起。我正在尝试查看KafaStreams是否适合分发工作然后加入。
我可能不建议对数据本身使用kafka流,因为它并不意味着处理像视频这样的大消息。但是您可以将其用作消息传递系统,说:
希望有帮助。