11_Брокеры сообщений

[Kama-Pushka]

• Реализовать два сервиса, способные обмениваться сообщениями с использованием одного из сервисов (на выбор ActiveMQ, RabbitMQ, Kafka) (Kafka)
• Тело сообщения должно быть в формате JSON
• Пришедшее сообщение выводить в лог (изображение)
• В README приложить ссылку на репозиторий со вторым сервисом или в одном репозитории указать какой проект к чему относится (на выбор) (producer - отправитель, consumer - получатель)

[Kama-Pushka]

Параметры @KafkaListener

id - уникальный id слушателя.
containerFactory - имя бина, который используется для создания контейнера слушателя.
topics - конкретные топики для прослушивания.
topicPattern - шаблон топиков для прослушивания.
topicPartitions - партиции для прослушивания.
containerGroup - имя бина, к которому будет добавлен контейнер этого слушателя.
errorHandler - обработчик ошибок.
groupId - группа потребителей для распределения сообщений.
idIsGroup - флаг использования id как groupId.
clientIdPrefix - префикс, добавляемый к id.
beanRef - ссылка на бин, в котором определен слушатель.
concurrency - число одновременно работающих потоков для обработки сообщений.
autoStartup - автостарт слушателя при загрузке приложения.
properties - эти свойства заменяют любые свойства с таким же именем, определённые в фабрике потребителя.
splitIterables - флаг разделения коллекций сообщений на отдельные элементы.
contentTypeConverter - имя бина для десереализации содержимого сообщений.
batch - обработка сообщений пачками.
filter - обработка сообщений, соответствующих фильтру.
info - описание слушателя.
containerPostProcessor - имя бина для настройки контейнера после его создания.