monix/monix-kafka

Version 0.14 not published for Scala 2.12

1015bit opened this issue · 9 comments

1015bit commented

In maven central the latest version for monix-kafka-10_2.12 seems to be 0.13

https://search.maven.org/#search%7Cga%7C1%7Cmonix-kafka

alexandru commented

Argh, OK, not sure what went wrong, will fix.

1015bit commented

Thanks for the quick reply! 🙂

1015bit commented

Is there some other repo that I could use in the meantime?

alexandru commented

I'm publishing it right now. 0.13 should also work with Monix 2.3.0, since I kept binary compatibility.

alexandru commented

OK, so I published the packages on Sonatype, should take about 5 minutes to synchronise to Maven Central.

Unfortunately this happened because this project uses the sbt-doge plugin to specify different Scala versions, due to the Kafka 8 client not supporting Scala 2.12 😠 and well, it misfired.

1015bit commented

Great! Thanks a lot! 🙂

Btw, the reason I was asking for another repo was because val observable = KafkaConsumerObservable[String,String](consumerCfg, List("my-topic"), io) didn't work for me in 0.13. But afaik the signature for apply looks the same for 0.14 so I guess it's just the readme that's slightly outdated(?) 😉

alexandru commented

@pbvie sorry, yes, it no longer has the io parameter. To get the same effect you can do:

KafkaConsumerObservable[String,String](consumerCfg, List("my-topic")).executeOn(io)
alexandru commented

Monix also has asyncBoundary (to jump the execution back to the default EC, which is usually global) and the latest version (2.3.0) also has observeOn which is an asyncBoundary that allows specifying a concrete EC.

Samples:

source.executeOn(io).asyncBoundary(BackPressure(1024))

source.executeOn(io).observeOn(computation)
1015bit commented

Thanks for the explanation!