pulsar4s

pulsar4s copied to clipboard

Updates * [org.apache.logging.log4j:log4j-api](https://gitbox.apache.org/repos/asf?p=logging-log4j2.git) * [org.apache.logging.log4j:log4j-slf4j-impl](https://gitbox.apache.org/repos/asf?p=logging-log4j2.git) from 2.17.2 to 2.18.0. I'll automatically update this PR to resolve conflicts as long as you don't change it yourself. If you'd like to skip...

scala-steward

Updates [dev.zio:zio-interop-cats](https://github.com/zio/interop-cats/) from 2.5.1.1 to 22.0.0.0. [GitHub Release Notes](https://github.com/zio/interop-cats/releases/tag/v22.0.0.0) - [Version Diff](https://github.com/zio/interop-cats/compare/v2.5.1.1...v22.0.0.0) I'll automatically update this PR to resolve conflicts as long as you don't change it yourself. If you'd...

scala-steward

Updates [dev.zio:zio](https://github.com/zio/zio) from 1.0.16 to 2.0.0. [GitHub Release Notes](https://github.com/zio/zio/releases/tag/v2.0.0) - [Version Diff](https://github.com/zio/zio/compare/v1.0.16...v2.0.0) I'll automatically update this PR to resolve conflicts as long as you don't change it yourself. If you'd...

scala-steward

Updates [com.sksamuel.avro4s:avro4s-core](https://github.com/sksamuel/avro4s) from 4.0.13 to 4.1.0. I'll automatically update this PR to resolve conflicts as long as you don't change it yourself. If you'd like to skip this version, you...

scala-steward

Cats Effect 3 migration

2

Hello everybody. This mr updates cats effect to cats effect 3. Things to notice: * fs2 also updted * monix doesn't support ce3 yet, so I commented out this test...

amalinkoevo

Release for Scala 3

4

It would be nice to have a release for Scala 3

hejfelix

Updates com.fasterxml.jackson.core:jackson-databind from 2.13.1 to 2.13.2.2. I'll automatically update this PR to resolve conflicts as long as you don't change it yourself. If you'd like to skip this version, you...

scala-steward

When im using Json schema, even though the records are being written as json it seems like the schema doesn't get attached to the topic? i.e pulsar-admin schemas get gives...

polyzos

Akka source creation function should return a future

2

It should be possible to pass a `() => Future[Consumer[T]]` to create the Akka source, so we can easily use the async consumer creation API and avoid blocking the Akka...

gmethvin

producer.send does not strip ""

3

Example code ```scala val client = PulsarClient("pulsar://localhost:6650") val producer_topic = Topic("test") val producer = client.producer[String](ProducerConfig(producer_topic)) producer.send("Hello,World,1") ``` When sending this as a String and receiving a Array[Byte] pulsar4s does not...

Haaroon