是否可以使用 Litmus 来测试 kafka?基本上是一些测试来弄清楚在各种情况下会发生什么。最初的想法是:
- 为 kafka 部署 confluent helm chart 并检查代理获取存储绑定成功
- 杀死经纪人并确保它回来
- 杀死 zookeeper pod 并确保它回来
- 杀死消费者 pod(我自己的应用程序)并确保它们回来并且不会错过消息
- 杀死生产者 pod 并确保它返回并确保发送所有消息。
是否可以使用 Litmus 来测试 kafka?基本上是一些测试来弄清楚在各种情况下会发生什么。最初的想法是:
我假设您的意思是像小型混沌工程测试一样的 Litmus 测试,并且我还假设您的意思是在 Kubernetes 中进行。是的,只要您将所有 pod 定义在更高级别的抽象中,例如Deployment、DaemonSet和StatefulSet ,您就应该能够做到这一点,它们本质上会创建一个ReplicaSet。
在 Kubernetes 世界中,要强制执行此测试,您只需删除运行 Kafka/Zookeeper 工作负载的 pod,它们应该由 ReplicaSet 启动到您的 pod。