дает

Ну я могу через Annotations.Aux[Key, A, AnnRepr]

Речь о транзакцилнном продюсере?

в сирке было вроде раньше, в кодеках использовалось (circe-generic-extras)

Точно, там же есть что-то с JsonKey. Спасибо, пошукаю!

в сирке женерик экстра будет пример через шаплез; шаплез 3 тоже имеет Annotations (это вроде единственное что там есть лол); но в целом тебе не надо шаплез тащить чтоб достать аннотации

да, именно о нем

Ну вообще похоже на внутреннюю ошибку Кафки на фоне ребаланса. Ошибка Retryable?

https://habr.com/ru/company/tinkoff/blog/481784/

"...
Но есть еще один нюанс. Transactional.id, который мы настраивали выше, на самом деле является префиксом транзакции. На менеджере транзакций к нему дописывается порядковый номер. Полученный идентификатор выдается на transactional.id.expiration.ms, который конфигурируется на Kafka кластере и обладает значением по умолчанию «7 дней». Если за это время приложение не получало никаких сообщений, то при попытке следующей транзакционной отправки вы получите InvalidPidMappingException. После этого координатор транзакций выдаст новый порядковый номер для следующей транзакции. При этом сообщение может быть потеряно, если InvalidPidMappingException не будет правильно обработан.
"

выставил у себя на локальной кафке transactional.id.expiration.ms=120000

но как-то странно
эта ошибка возникает не через 2 минуты, а спустя минут 20

Возьми магнолию

Сделай тупкласс Анонатионс[А]

И там в один метод тащи

Всем привет!
Как slick научить работать с Обьектами у которых какой-то ключ содержит массив (строк)?

love you long time!

Это макросом своим надо делать

Господи, гребаные гумоноиды

Почему  не использовать тайпалиас и нэймоф?

Аннотации сразу тянут за собой воспоминания о джаве, а тайпалиас и имя типа вполне себе  хороши