Steviep

Hi @vincentfree , Does this test case do what you're looking for? Or is there some other functionality specifically you're looking for? https://github.com/salesforce/kafka-junit/blob/master/kafka-junit-core/src/test/java/com/salesforce/kafka/test/KafkaTestClusterTest.java#L235-L329

Hmm, no such method exists today, tho it is an interesting use case. I'll poke around and see if I can come up with anything. The underlying `KafkaServerStartable` doesn't provide...

Both sound like valid use cases to test against. Unfortunately I don't believe Kafka exposes mechanisms to do what you're looking for. Regarding async shutdowns, it may be possible to...

Which logging framework do you use? The configuration will vary depending on what your project is using to handle logging. For example, the tests in this project uses log4j as...

Sure, let me pull down the branch and see what tests pass/fail for me.

So I'm running on OSX, and excluding the tests that require the special JVM options (KafkaSaslSslClusterTests, KafkaSaslClusterTests) the only test that fails for me is `ConsumerGroupOffsetsTest.testSerialization()` Are you able to...

It looks like the failure in `ConsumerGroupOffsetsTest.testSerialization()` is just the order of elements being serialized in the final json string is slightly rearranged.

Do you happen to know which test it is? I'm guessing `KafkaOperationsTest.testRemoveTopic()`? If so, it likely is safe to locally comment out / bypass that test as you're unlikely to...

Also you can run the commend `mvn clean install -DskipTests=true` to bypass running the test suite.

This is a really interesting idea! I wonder if we should just add your new interface into kafka-webview-plugin? It would be cool if we could have it work for both...