kafka-junit
kafka-junit copied to clipboard
JUnit rule for spinning up a Kafka broker
Running JUnit EphemeralKafkaBrokerTest on Windows is failing: ``` 11:08:19.131 [onPool-worker-1] WARN k.server.BrokerMetadataCheckpoint - No meta.properties file under dir C:\Users\KASSOV~1.MAR\AppData\Local\Temp\kafka_junit2358289997418960258\meta.properties 11:08:19.764 [onPool-worker-1] WARN k.server.BrokerMetadataCheckpoint - No meta.properties file under dir C:\Users\KASSOV~1.MAR\AppData\Local\Temp\kafka_junit2358289997418960258\meta.properties...
When there are multiple messages in topic and consumeStrings() is called with number of messages less than number present in there, the extra messages will be discarded. Example: ```java @ClassRule...