我需要在Java中编写一个冒烟测试,验证系统是否连接到kafka,
有谁有想法吗？我发现这篇文章:
如何检查Kafka Server是否正在运行？
但是从Java代码中做起来太复杂了,我不认为这是我应该使用的方向.
提前致谢.
java smoke-testing apache-kafka
apache-kafka ×1
java ×1
smoke-testing ×1