Read the blog and test example. I’m not an active kafka user just knowing some basic concepts so I might miss understanding something here. But I feel the system under test is kind of hiding behind test fixture, isn’t it strange? I think I would prefer to see system under test is explicitly setup in the test more clearly.

With this current setup, I’m not sure how to switch system under test to something else like ruby on rails