即使Kubernetes就绪探测失败，Pod也能接收通信

Question

readinessProbe:
  exec:
    command:
    - cat
    - /tmp/healthy
  initialDelaySeconds: 5
  periodSeconds: 5

Readiness probe failed: cat: can't open '/tmp/healthy': No such file or directory

1）kafka消息已被我的应用程序使用并保存到数据库中。
2)无法访问rest api。

我假设如果Pod的准备探测失败，应用程序既不能接收kafka消息，也不能接收rest请求。但为什么在我的测试中，REST请求和Kafka消息的处理方式不同。

根据Kubernete文档：

The kubelet uses readiness probes to know when a Container is ready to start accepting traffic

Answer 1

这是两件非常不同的事情：

• 接收请求：外部服务正在发送请求并期望响应。
• 发送请求：您的服务正在发送请求并等待响应。

当ReadinessProbe失败时，不会将任何新的请求路由到Pod。

无法打开“/tmp/health”：没有这样的文件或目录

如果服务需要/tmp/health目录才能正常工作，则服务应在启动时检查该目录，如果所需的目录不可用，则应检查exit(1)（崩溃时出现错误消息）。这应该在连接到Kafka之前完成。如果您的应用程序持续使用该目录，例如写入该目录，则应检查并正确处理任何操作错误代码--根据您的情况记录和崩溃。

我的实际意图是使我的服务应用程序（kafka consumer）能够控制何时接收kafka消息（以及REST请求）。例如。如果有大量操作，我的服务将删除/tmp/health文件，从而使pod无法接收kafka消息和Rest请求。

Kafka消费者投票Kafka获得更多的数据，只要消费者想要。换句话说，Kafka消费者只要准备好获取更多的数据，就会要求获取更多的数据。

消费者代码示例：

 while (true) {
     ConsumerRecords<String, String> records = consumer.poll(100);
     for (ConsumerRecord<String, String> record : records) {
         // process your records
     }
 }

记住commit处理过的记录，这样消息就不会被多次处理，例如在崩溃之后。