Scala User Group

06 Feb 2023 18:57

Добыл книгу Functional event-driven architecture
Нашел как люди в третьей скале с Кафкой и фс2 работают и постоянно вопрос, а так можно было?

Scala User Group

06 Feb 2023 18:07

я другой метод не нашел - я в итоге от этой затеи отказался
сделал просто ручной откат если эффект вернул ошибку

Scala User Group

06 Feb 2023 17:15

А не в целом где посмотреть общую идею можно как это запилить? В книгах про катс? Фс2? Статьи может?
Пытаюсь скрестить ужа и ежа и есть проблемы.
Создаю допустим stream на 42 объекта моего кейс класса, это будет Stream[IO, User].
Потом вызываю из объекта Fs2Producer make и получаю IO[Fs2Producer[User].
Вот мне казалось, что должно сработать что-то типа
stream.flatMap(x => producer.publish(x)
А потом producer.run

Но что-то не срабатывает, и пишет, что в producer нет метода run.

Scala User Group

06 Feb 2023 16:35

/channel/docker_ru
/channel/proKafka

Scala User Group

06 Feb 2023 16:00

Приветствую! Мб тут смогут подсказать:

Вопрос по кафке:

Кто-нибудь знает, есть ли отличия между сертификатами для кафки на 2-ом спарке и на 3?

Может ли быть такое, что нужны другие сертификаты УЦ и т.п.?

При запуске на спарк 2 всё работает, однако при смене нужных jar файлов и запуске на 3 спарке, выдаёт ошибку

org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed
Stdoutput Caused by: javax.net.ssl.SSLHandshakeException: No subject alternative names presen

#9: ObjectId: 2.5.29.17 Criticality=false
SubjectAlternativeName [
  DNSName: 00CA..
]

Scala User Group

06 Feb 2023 15:38

нет, создаю очередь на 42 элемента, в эту очередь можно положить 42 раза, на 43 вставка встанет ожидая освобождения места

Scala User Group

06 Feb 2023 13:41

Узнал в чем проблема и куда идти, к окулисту.
VSCode воткнул импорт левый, а я недосмотрел

Scala User Group

06 Feb 2023 13:25

Я хоть теперь слова знаю чтоб понтоваться😺, то есть о проблеме гуглить
А вот если в такой имплисите ругается

Type argument T does not conform to upper bound domain.Base
implicit def s[T <: Base]: Serializer[IO, T] = Serializer[IO].contramap[T](setData[T])

Scala User Group

06 Feb 2023 13:17

Вообще куда копать? Это Темплейты раскапывать? Что вообще почитать для просветления?

Scala User Group

06 Feb 2023 13:08

Потому что такой опции нет в скале 3.

Scala User Group

06 Feb 2023 13:05

В скасти и -Ydelambdafy:inline работает, а в sbt не нагуглю как воткнуть чтоб не игнорило

Scala User Group

06 Feb 2023 13:04

во второй скале надо иметь объект сверху

Scala User Group

06 Feb 2023 13:02

Ее как выткать? Посылает

bad option '-Ydelambdafy:inline' was ignored

Scala User Group

06 Feb 2023 12:54

Все же вот это строку для третьей скалы еределать можно?

class Fs2Producer[T: Serializer[IO, *]](topic: String, url: String, queue: Queue[IO, T]) {

class Fs2Producer[T: Serializer[IO, _]](topic: String, url: String, queue: Queue[IO, T]) {

Scala User Group

06 Feb 2023 12:27

Вот так?

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

Scala User Group

06 Feb 2023 18:56

а я в транзакции пытаюсь сохранить в бд и потом отправить в кафку сообщение и если отправка падает, то транза в бд откатывается успешно. как можно будет такое вручную откатить?

Scala User Group

06 Feb 2023 17:53

сорри, что поднимаю старый тред, в итоге кроме как оборачивания в WeakAsync.liftK[F, ConnectionIO].use, нет никаких вариантов? слишком много кода приходится переписывать

Scala User Group

06 Feb 2023 16:41

всем привет! ищу автора, который бы смог написать статью для IT-медиа на тему «План перехода с Java на Scala». Будет здорово, если у вас уже есть опыт написания статей

если кому-то из вас было бы интересно взяться за текст, напишите мне)

Scala User Group

06 Feb 2023 16:32

Есть каналы типа pro.kafka или docker там devops`ы тусуются, может там скорее ответят?

Scala User Group

06 Feb 2023 15:48

publish кладет в очередь, а run у потока освобождает место?

Scala User Group

06 Feb 2023 15:37

Метод объекта make внутри создает очередь из 42 Producer, дальше flatMap по этой очереди и пихаешь в public создаваемый объект? Это типа так?

Stream.range(1,99999).mapAsync(25){ x => Fs2Producer.make[User]("topic", "localhost:9092").flatMap( data => data.publish(User(x, "one", None)))}

Scala User Group

06 Feb 2023 13:27

/channel/scala_learn

Scala User Group

06 Feb 2023 13:19

В чем ваша проблема? Чтобы в скале 3 андерскоры работали в тайплямбдах, нужна опция -Ykind-projector:underscores, деламбдафай в скале 3 не нужен. Все.

Scala User Group

06 Feb 2023 13:11

И как быть? Малой кровью значит не обойти проблему

Scala User Group

06 Feb 2023 13:05

3.2.2

name := "kafka-avro"

version := "1.0"

scalaVersion := "3.2.2"

scalacOptions ++= Seq(
  "-deprecation",
  "-encoding", "UTF-8",
  "-feature",
  "-unchecked",
  "-Ydelambdafy:inline"
)

libraryDependencies ++= Seq(
      "com.sksamuel.avro4s" %% "avro4s-core" % "5.0.3",
      "com.github.fd4s" %% "fs2-kafka" % "3.0.0-M8",
      "dev.zio" %% "zio-kafka" % "2.0.6",
      "org.slf4j" % "slf4j-api" % "1.7.5",
      "org.slf4j" % "slf4j-simple" % "1.7.5"
)

Scala User Group

06 Feb 2023 13:04

Так же как любую другую опцию компилятора. Например, scalacOptions += “-Ykind-projector:underscores”

Scala User Group

06 Feb 2023 13:04

в скасти воркшит режим

Scala User Group

06 Feb 2023 12:57

-Ykind-projector:underscores

Scala User Group

06 Feb 2023 12:52

Во второй скала вроде в объект это все всандаливать надо, а скасти без объекта обходится неявно

Scala User Group

06 Feb 2023 12:25

а setData с T <: Base у тебя же был, а тут просто T, приведи к корректным типам