Извлечение из Кафки: Полное руководство
Сообщение - это просто массив байтов в отношении Кафки, поэтому содержащиеся в нем данные не имеют определенного формата или значения для Кафки,Сообщение может иметь дополнительный бит метаданных, который называется ключом.Ключ также является байтовым массивом и, как и в случае с сообщением, не имеет особого значения для Кафки.
Итак, настоящий вопрос здесь таков: Каковы преимущества хранения данных в байтовом массиве?
Массив байтов - это общий формат данных, и практически любой тип данных, который мы знаем (или пользовательские типы, созданные разработчиками), можно сериализовать / десериализовать в / из байтового массива.
@ aran привел отличные примеры в комментарии.Просто чтобы добавить еще одну причину, нам не нужно заботиться о схемах и проверке сообщений в Kafka.Это просто магазин ... Представьте себе 500 приложений, работающих и производящих / потребляющих к / от Кафки.Может быть 500 различных схем и типов данных (String, Int, Json, XML и т. Д.) И более 500 критериев проверки сообщений.Но это конечные операции приложения.Таким образом, платформа обмена сообщениями, такая как Kafka, не должна заботиться об этих форматах и должна предоставлять общий способ хранения всех типов данных, что она явно делает.:)
Надеюсь, это поможет!:)