Yuriy Badalyants
Yuriy Badalyants
Current publishing schema is pretty inconvenient. It would be cool to have this lib in the maven central or any other public repository.
After updating from this set of dependencies: ```scala val korolev = "1.2.0" Seq( "org.typelevel" %% "cats-effect" % "2.5.1", "co.fs2" %% "fs2-core" % "2.5.6", "org.http4s" %% "http4s-blaze-server" % "0.21.1", "org.fomkin" %%...
Look at this fiddle: http://jsfiddle.net/tYRn5/ It fails on 11 line. I found, that problem occurs in clone function, on line 100: ``` var copy = obj.constructor(); ``` In case of...
Currently, there is no way to get a `TypeTag` for a newtype: ```scala @newtype case class WidgetId(toInt: Int) val widgetId = WidgetId(5) import scala.reflect.runtime.universe._ val tt = typeTag[WidgetId] // failed...
In my project I want to have custom logger, based on scala-logging `Logger` class. But for now there is no possibility to create custom logger. `Logger` class is final and...
Fix for #994
After an https://github.com/fd4s/fs2-kafka/pull/844 `partitionsMapStream` is no more a "`Stream` where each element contains a current assignment" as was mentioned in the scala doc previously. It looks like if we want...
From [here](https://github.com/fd4s/fs2-kafka/issues/889): At the current moment, consumer internals are pretty complex: we have a `KafkaConsumer` itself, a hand-maded `KafkaConsumerActor`, a queue for messages. Also, there is some complexity with different...
Recently I have worked with the `CommitRecovery` functionality. And I found that this part of the library is not pleasant to work with. In particular, I faced the next issues:...
During the discussion of https://github.com/fd4s/fs2-kafka/pull/409 I suggested that `commit` method from the `CommitableOffset` could be moved to the `KafkaConsumer`. `CommittableOffset` feels like pure data, but it contains `def commit: F[Unit]`,...