Кто писал сообщения в Kafka? Как происходило изменение формата сообщений?