Scala User Group

06 Feb 2023 12:23

А вообще как может в скасти код не крснить, а локально не компилится, на

implicit def s[T]: Serializer[IO, T] = Serializer[IO].contramap(setData)

expected start of definition

Scala User Group

06 Feb 2023 11:24

https://scastie.scala-lang.org/eJzdASDpSeqXHvd39ZFxEA попрвил зависимости и даже не краснит )

Scala User Group

06 Feb 2023 11:21

я думаю @ajIeks сможет лучше подсказать

Scala User Group

06 Feb 2023 11:18

андекрскоры теперь в 3 скале

Scala User Group

05 Feb 2023 17:50

Возможно. Только, почему-то ничего приличней https://getquill.io/#contexts-quill-cassandra на ум не прихрдит.

Scala User Group

05 Feb 2023 17:35

А, сама она довольно простая надстройка над стримами, которые форкнули. Почему-то думал, что и альпакки тоже. Но - пока нет (или я не нашел)

Scala User Group

05 Feb 2023 17:06

Нет. Это про другое. Форка альпакки может и не быть :(

Scala User Group

05 Feb 2023 17:00

Вот допустим использую алпакка Кассандра
Там форк апача это что? Для акко это пекко, а для альпака Кассандра? Apache Pekko Persistence Cassandra?

Scala User Group

05 Feb 2023 16:54

Это которая для json?

Scala User Group

05 Feb 2023 16:44

Похожее на circe.Encoder

Scala User Group

05 Feb 2023 16:38

class MyKafkaThingService[A: MyDataSerializerTypeclassThatConvertsAToBytes]

Scala User Group

05 Feb 2023 16:12

Не то копирнул, там confluentinc/cp-kafka:7.3.0 должно быть

Scala User Group

05 Feb 2023 14:54

Нет, дополнительно, зукипер нужен самой кафке

Scala User Group

05 Feb 2023 14:48

https://github.com/provectus/kafka-ui/blob/master/docker-compose.md

Scala User Group

05 Feb 2023 14:41

Про тип: втащи в кафка-юи в докере чтоб видеть попроще какие топики есть и месаги

Scala User Group

06 Feb 2023 11:30

Спасибо.
А для третьей скалы как переделать

[T: Serializer[IO, *]]

[T: Serializer[IO, _]]

fs2.kafka.Serializer[cats.effect.IO, ?] does not take type parameters

Scala User Group

06 Feb 2023 11:21

как автор оригинального скасти (вроде)

Scala User Group

06 Feb 2023 11:19

Но я так понимаю это если сериализацию выкинуть из класса?
И делать ее имплиситом? А получится без ContextShift?

Scala User Group

05 Feb 2023 17:57

Тоже из нагугленного запал чемто, надо попробовать будет

Scala User Group

05 Feb 2023 17:42

Хотя наверное если акка не нужна то лучше иной драйвер для Кассандры поискать

Scala User Group

05 Feb 2023 17:33

В данном случае вы под альпакой что имеете ввиду? На странице альпаки драйвер для Кассандры и вроде на странице пекко то же драйвер. То есть могу по идее для работы с Кассандрой использовать пекковский драйвер, не ?

Scala User Group

05 Feb 2023 17:03

Да. Это как пример паттерна

Scala User Group

05 Feb 2023 16:55

Можете и в проде, но либо форк апача, либо предидущую версию либо да, за деньги.

Scala User Group

05 Feb 2023 16:54

Я правильно понимаю, что альпакские либо использовать для пет проекта могу, но если проект начнет приносить деньги, то нужно покупать коммерческую лицензию?

Scala User Group

05 Feb 2023 16:42

Так понимаю когда научусь плавать, в бассейн воду нальют😺
MyDataSerializerTypeclassThatConvertsAToBytes в данном контексте как должен выглядеть? Это сериализатор на основе авто в моем случае?
Это trait от которого наследовать конкретные классы для конвертации моих данных в авро байтовый массив?

Scala User Group

05 Feb 2023 16:30

У меня архитектурные вопросы нарисовались.
Допустим я хочу класс замутить, обертку над оберткой, чтоб где надо создавать Producer и ему данные передавать. Указал топик, url к кафке и вперед.
Но вот скажем для zio-kafka надо ZStream создать, потом при помощи mapZIO, в который передаем лямбду создающую из элемента потока сообщение, и drain создаем ZStream[Producer, Throwable, Nothing] к примеру. А потом через runDrain и provide запускаем процесс на выполнение. В стандартном примере zio-kafka создася поток случайных чисел, а потом в виде строки передается на producer который дальше пишет в топик.
Если я хочу большей универсальности, то мне достаточно сменить тип сообщения на bytearray,
а дальше сделать поток из сериализованных Avro данных?

Scala User Group

05 Feb 2023 15:00

Можешь и кафку и зукипер и Кафка Юи из докер компоуза катить

Scala User Group

05 Feb 2023 14:51

То есть вместо confluentinc/cp-kafka:7.3.0 прописать provectuslabs/kafka-ui и порт прокинуть 8080?

Scala User Group

05 Feb 2023 14:47

Вот тут можно подробнее? Гуглить за docker-ui?

Scala User Group

05 Feb 2023 14:41

https://github.com/akka/alpakka/blob/master/LICENSE