{"repo":"mguenther/kafka-junit","free":true,"listed":false,"github":"https://github.com/mguenther/kafka-junit","clone":"git clone https://github.com/mguenther/kafka-junit.git","description":"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 external clusters as well.","language":"Java","stars":57,"topics":["kafka","kafka-connect","junit"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":"Kafka for JUnit [!IMPORTANT] Kafka for JUnit will not be updated regularly any longer. Unfortunately, I do not have the time to allocate my attention to this project in a sustainable fashion. Updates and bugfixes may still happen (support for new versions, ...), but if they do, it will be solely based on my personal requirements. Thank you for your understanding. Kafka for JUnit enables developers to start and stop a complete Kafka cluster comprised of Kafka brokers and distributed Kafka Connect workers from within a JUnit test. It also provides a rich set of convenient accessors to interact with such an embedded Kafka cluster in a lean and non-obtrusive way. Kafka for JUnit can be used to both whitebox-test individual Kafka-based components of your application or to blackbox-test applications that offer an incoming and/or outgoing Kafka-based interface. Using Kafka for JUnit in your tests Kafka for JUnit provides the necessary infrastructure to exercise your Kafka-based components against an embeddable Kafka cluster. However, Kafka for JUnit got you covered as well if you are simply interested in using the convenient accessors against Kafka clusters that are already present in your infrastructure. Checkout sections Working with an embedded Kafka cluster and Working with an external Kafka cluster in the user's guide for more information. This starts an embedded Kafka cluster and submits three records to the topic named test-topic . The call to kafka.observe(on(\"test-topic\", 3","default_branch":null,"files":null,"tree":[],"storefront":"/r/mguenther","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/mguenther/kafka-junit/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}