Я предлагаю вам использовать одну тему о датчиках с полезной нагрузкой имени датчика (или предпочтительно UUID), чтобы вы знали , какой датчик отправил данные и данные, которые он генерирует, как одно целое сообщение ,
В противном случае, объединение данных исключительно по метке времени не кажется надежным доказательством.
Ваш ключ сообщения может быть UUID / именем, и вы можете масштабировать его до сотен разделов
Вы можете двоично кодировать данные, которые вы отправляете, но я буду использовать строку JSON для иллюстрации
{
"sensor_id" : "some unique name",
"temperatures" [1,2],
"voltage": 3
}
Если вам нужны три темы из этого, вы можете очень легко создать три темы вывода, используя Kafka Streams или KSQL
Иначе, создавайте отдельные темы, но добавьте идентификатор / имя, чтобы вы могли присоединиться к нему, используя окна времени с порядком секунд или минут, не пытаясь отрегулировать задержку, когда один событие отключено, и вы не можете присоединиться к сообщениям