такое опять же может делать любое из решений из коробки без особенного бойлерплейта

библиотеки все низкого качества, но это стандартный функционал

для продьюсера

Собственно потому я интересуюсь, это надо самим раббитом или поверх раббита библиотеки или вообще что то другое смотреть.
Что для чего предназначено и как можно использовать.
Про раббит, кафку, протобуф я слышал, потому про них как то гуглю, книги пытаюсь почитать и тд, а вот что еще может быть полезного для взаимодействия микросервисов, я как бы не совсем в теме, мой опыт синхронных асинхронных интерфейсов из области SAP Abap, а там это специфично

это немного старая версия репы

вот обновляемая и с большим количеством звезд

https://github.com/lauris/awesome-scala

только не говорите владимиру что с абапа перелазите

Я не перелазю, я для расширения кругозора 😺

лучше перелазьте

ничего не нужно, пример из питонокода

import pika

...

rabbit_channel.confirm_delivery()
is_published = rabbit_channel.basic_publish(exchange='',
                             routing_key='myrt',
                             body=rabbit_message_json,
                             properties=pika.BasicProperties(delivery_mode = 2) # make message persistent
                             )

confirm_delivery

как раз отвечает за подтверждение со стороны реббита что всё запаблишилось, и деливери мод 2 чтобы засторилось и не удалится случайно при ребуте

ну это не акк же всё равно

Для перелаза надо тему подучить и кругозор расширить.
А я сейчас на стадии петпроекта застрял, читаю книгу про микросервисы, хочу запилить пет проект с микросервисами на scala/go, но вот пока намечаю карту местности для перелаза 😺

В общем если сравнивать с ABAP, есть два режима первый аналогичный
call function ... destination
.. in background task

такое делают каждый день все на кафке, реббите, пульсаре и чём ни попадя

второе
call function ... destination ...
такое обычно делается не с помощью брокеров а с помощью rest, grpc и т.п.

если вы называете первое асинхронным, а второе - синхронным, то да, для асинхронного всё есть, оно среднего качества, но жить можно

микросервисы ортогонально очередям. И обычно они общаются по хттп, либо напрямую в простых кейсах, либо через какой-то балансировщи в более сложных

конфиг прописать. Органаийз импорт не зависит от металса или идеи

у меня есть вродь .scalafix.conf в руте

OrganizeImports.groupedImports = Explode
OrganizeImports.groups = [
 "java",
 "scala.",
 "derevo.",
 "cats.",
 "zio.",
 "tofu.",
 "io.",
 "io.circe",
 "derevo.",
 "cats.effect.",
 "fs2.",
 "sttp.",
 "org.http4s.",
 "doobie.",
 "monix.",
 "com.tochka."
]

вот такое в него нужно добавить

сейчас перепроверю

естесно с переделками под себя

этот будет разгруппировывать импорты и вставлять ньюлайны