scala-kafka-client
scala-kafka-client copied to clipboard
Scala helper modules for operating the Apache Kafka client library (0.9.x - 2.1.0)
Hi, I think the 2.0.0 version dependencies stated below work in SBT environment but seems not working for maven. scala-kafka-client_2.12 scala-kafka-client-akka_2.12 scala-kafka-client-testkit_2.12 I am using Maven and encountering The POM...
I've updated most dependencies and fixed all deprecations as well. However, I'm running into this error: ``` [error] Test suite cakesolutions.kafka.ConsumerProducerIntSpec failed with java.lang.NoClassDefFoundError: scala/math/Ordering$$anon$7. [error] This may be due...
`sbt.librarymanagement.ResolveException: unresolved dependency: net.cakesolutions#scala-kafka-client-akka_2.13;0.11.0.0: not found`
Addresses #122
Updating SBT to >= 1.3.8 should allow using JitPack to grab the latest changes from Git.
Its been a while since kafka 2.4 is released. The client needs to be updated to support kafka client driver 2.4
In order to use scala-kafka-client we have to add cakesolutions repo explicitly: ```scala resolvers += Resolver.bintrayRepo("cakesolutions", "maven") ``` It's so inconvenient. Issues #143 and #146 were created solely due to...
Hi there! Is it possible to use a Zookeeper Ensemble instead of Kafka Bootstrap Server to connect to cluster? Or any future plans that will support Zookeeper? Regards Jaschar
Is it possible to share underlying KafkaConsumer thread or KafkaProducer thread among ConsumerActor and ProducerActor, respectively; similar to [alpakka-kafka](https://doc.akka.io/docs/akka-stream-kafka/current/consumer.html) ?