我想用apachekafka创建一个简单的基于传感器数据的应用程序。我的问题非常简单，并且引用了apachekafka的基本概念。我是ApacheKafka的初学者。
这是我的要求：
我通过一个字节数组得到传感器数据，里面有不同的数据。例如，数组有三个条目（温度1、温度2和电压）。下面是一个包含4个数组和值数据的示例。每个数组都有一个定义的时间戳。
阵法一：[1，2，3]
阵法二：[4，5，6]
阵法三：[7，8，9]
阵法四：[10，11，12]
现在我要阅读这些数组，并为以下三个主题生成消息：
主题-temp1
主题-temp2
主题电压
生产顺序为：
读取数组1
向topic-temp1生成消息（值=1）
向topic-temp2生成消息（值=2）
向主题电压生成消息（值=3）
读取数组2
向topic-temp1生成消息（值=4）
向topic-temp2生成消息（值=5）
向主题电压生成消息（值=6）
读取数组3
向topic-temp1生成消息（值=7）
向topic-temp2生成消息（值=8）
向主题电压生成消息（值=9）
... 读取数组n。。。
之后我有3个主题，里面有不同的数据：
主题1:1、4、7、10
主题2:2，5，8，11
主题电压：3，6，9，12
现在我的问题是：我想创建一个使用这3个主题的软件应用程序。我想在一个图中显示3个图形（temp1，temp2，voltage）。y轴是信号值，x轴是时间戳。
如何保证在同一时间戳上获取已消耗的值？只有我能覆盖图表。
1,2,3
4,5,6
7,8,9
10,11,12
我应该使用kafka流api吗？一个输入流主题（字节数组）和三个输出流主题？如何确保这三个价值观一起产生，一起消费？
或者我应该使用一个简单的使用者api，通过偏移值访问数据。因为条目（1,2,3）（4,5,6）的偏移量应该相同，因为我是按这个顺序生成的？
提前谢谢！