Введение
Введением является часть первая, данного повествования.
Подготовка
Действо
Использовать буду обработку из первой части которая засылает "Привет мир" в топик "1c.topic".
Итог:
В этом примере приведено чтение сообщения с использованием автосдвига.
Бонусом, в обработке которая приложена к публикации есть еще такая кнопочка:
А теперь представьте, вот мы научились отсылать, получать сообщения, а дальше нам надо строить распределенную трассировку к этому, вот в этой статье про нее писал #APMЭтоПросто: APM Adapter 1C (elastic).
Думаю если тут сто плюсиков наберется то к кафке прикрутим распределенную трассировку, через которую графически будет видно сколько времени ушло на отправку сообщения, сколько на его сериализацию, затем как другая система уже прочитала сообщение и сколько времени ушло на его обработку. Т.е. если например строить обмен по модели request-response то очень удобно можно будет проследить визуально весь путь : Запрос(система 1) -> Обработка запроса(система 2) -> Отправка ответа (система 2) -> Получение ответа(система 1).
Видео
Прочее:
Данная разработка: GitHub: 1С Kafka Confluent Adapter