我在到台机器（机器#1和机器#2）之间设置了kafka群集，配置如下：
1） 每台机器配置为运行一个代理和一个zookeeper。2） 服务器和zookeeper属性配置为具有多代理、多节点zookeeper。
我目前对Kafka制作人和Kafka消费者有以下了解：
1） 如果我从 machine#1 至 machine#2 ，使用一些默认分隔符（lf或\n）将其分解为行。2） 因此，如果machine#1将两个不同的文件发布到同一主题，这并不意味着 machine#2 将接收两个文件。相反，每一行都将附加到主题日志分区和 machine#2 将按到达顺序从日志分区中读取它。i、 e.顺序不同于

file1-line1
file1-line2
end-of-file1
file2-line1
file2-line2
end-of-file2

但可能是这样的：file1-line1 file2-line1 file1-line2 end-of-file1 file-2-line2 end-of-file2
假设以上是正确的（我很高兴错了），我认为简单的生产者-消费者使用传输文件不是正确的方法（这里可能是connectapi解决方案）。由于kafka网站上说“日志聚合”是一个非常流行的用例，我想知道是否有人有任何示例项目或网站来演示使用kafka的文件交换示例。
p、 我知道这一点 Connect API 说这是为了Kafka和“其他”系统之间可靠的数据交换——但我不明白为什么其他系统不能有Kafka。所以我希望我的问题不必集中在“其他”非Kafka体系上。