embeddedkafka/embedded-kafka
A library that provides an in-memory Kafka instance to run your tests against.
ScalaMIT
Pinned issues
Issues
- 0
Embedded Kafka does not work with Spark 3.5
#521 opened by adeshrd - 1
Looking for maintainers - help wanted
#515 opened by francescopellegrini - 4
v3.7.1 didn't get published
#509 opened by francescopellegrini - 0
- 1
- 11
Release process?
#455 opened by guizmaii - 2
embedded-kafka maintenance help
#442 opened by guizmaii - 3
Scala 3 support, pretty please :)
#411 opened by jozic - 6
ServerCnxnFactory is missing from the classpath
#383 opened by h-ngo - 2
Upgrade log4j dependency to supported version
#409 opened by robertjgtoth - 0
Support for kraft mode
#415 opened by ijuma - 1
Kafka 3.2.1 release
#386 opened by andreisilviudragnea - 6
- 0
Embedded kafka not starting after upgrading spring-boot-starter version to 2.3.12
#361 opened by nvsarath - 2
New release for Kafka 3.0.1
#352 opened by andreisilviudragnea - 4
- 1
Why is zookeeper.connection.timeout.ms set?
#286 opened by srdo - 0
Build for Kafka v3.0.0 client
#316 opened by andreisilviudragnea - 2
Cross compile with Scala2.13
#314 opened by paualarco - 1
Does embedded kafka automatically create topic even if I don't provide the @EmbeddedKafka(topics={"topic-name"},partitions = 3) in my integration test class
#293 opened by prottoyghose - 8
Unexpected exception in schema registry group processing thread org.apache.kafka.common.errors.WakeupException: null
#288 opened by SarpongAbasimi - 1
Deserializer custom types
#294 opened by SarpongAbasimi - 0
Several partitions
#287 opened by olgakabirova - 0
Coverage report action failing
#259 opened by francescopellegrini - 1
java.lang.NoClassDefFoundError: org/apache/kafka/server/authorizer/Authorizer when doing EmbeddedKafka.start()
#238 opened by srini-am - 3
Rename package?
#232 opened by amdelamar - 6
- 4
scala/math/Ordering not found after 2.5.0 update
#202 opened by edrevo - 1
How to use it with Java?
#197 opened by dxxvi - 4
- 1
- 1
Ask for help testing a topology with multiple consumers on multiple output topics.
#137 opened by mdespriee - 3
Timeout when wrapping an it clause in a withRunningKafka but not the other way around
#187 opened by cosminci - 1
Does embeddedKafka downloads kafka at run time
#150 opened by FuncGuy - 2
Please provide a way to create multiple brokers
#164 opened by michkhol - 2
Zookeeper dependency issue for version 2.2.1
#151 opened by PnPie - 5
- 8
- 4
Remove link to original fork
#50 opened by lukestephenson-zendesk - 0
I wanted to replace laravel queues with kafka by making kafka as queue driver. Will this package help me in that? If not pls suggest how could i achieve it.
#97 opened by shreyasmsglob - 12
Build with Scala 2.13
#33 opened by ennru - 4
Not sure if the example test is the old one
#82 opened by ppromsuban - 1
java.io.IOException: Failed to load /var/folders/td/4647jbb17bb3hcgnmh__5s0s9mhrhy/T/kafka-logs3458318621883604457.tmp during broker startup
#92 opened by JMVM - 3
multiple brokers
#63 opened by axaluss - 2
Support for SSL
#78 opened by politrons - 5
Support for kafka transactions?
#61 opened by patricenys - 2
Kafka server shutting down too fast
#51 opened by Vesli - 3
- 1
- 3
Deleting Topic From Embedded Kafka
#31 opened by shankarshastri