kafka-junit
kafka-junit copied to clipboard
mguenther
Enables you to start and stop a fully-fledged embedded Kafka cluster from within JUnit and provides a rich set of convenient accessors and fault injectors through a lean API. Supports working against...
### 🆕🐥 First Timers Only This issue is reserved for people who never contributed to Open Source before. We know that the process of creating a pull request is the...
I'm updating my connectors from kafka version to 2.8 to 3.0 and I'm having an error, that is likely not related to the Kafka Junit but I'm wondering if there...
* Reverse sort order of release version information * Drop release information for release lines 0.1.x, 0.2.x, 0.3.x * Only show latest available (patch) version for specific release line
I am trying to upgrade both my kafka client and the mguenther test library from 2.8 to 3.2, and I am getting lost messages causing my tests to fail at...
It is failing when it tries to start DefaultProducer as the SecurityProtocol is hardcoded as PLAINTEXT in getBrokerList for EmbeddedKafka
Typo in 1st example present in readme of kafka-junit. Test case failing. Please update kafka.observe(on("test-topic", 3)) in readme. ``` @Test void shouldWaitForRecordsToBePublished() throws Exception { kafka.send(to("test-topic", "a", "b", "c")); kafka.observe(on("test-topic",...
### 🆕🐥 First Timers Only This issue is reserved for people who never contributed to Open Source before. We know that the process of creating a pull request is the...
About 1 out of every 50 test runs on my MacOS dev machine I get a port conflict on the randomly assigned zookeeper ports. Would it be possible to validate...
hi... I'm looking at the code and I can't really find it, neither on my side, nor in here but is it possible to define random ports for the kafka-cluster?...