Using ZIO Kafka with offset storage in Postgres for transactional processing
Intro
Scala often gets a reputation for how complicated it is to write and setup and how much boilerplate there is. The same goes for functional programming. My goal is to show you the opposite — how even with limited knowledge of the following topic...
workshubtest.hashnode.dev18 min read
Dmitry Alexandrov
Hello, really helpful article, helps me a lot.
found small inaccuracy in this part of code:
private def topicPartitionFromString(s: String): Option[TopicPartition] = s.split("-").toList match { case t :: o :: Nil => o.toIntOption.map { offset => new TopicPartition(t, offset) } case _ => None }I suppose instead "offset" it must be partition