小编Yuv*_*val的帖子

我在具有Firebase的GCP中运行云功能。该功能非常简单，可以在Firestore中存储一些数据。

我在日志中看到以下错误： Error: cannot communicate with function. Function invocation was interrupted.

它发生在不到1％的请求中，但是我不明白为什么会这样。

我正在 Kubernetes 中运行 4 个代理 Kafka 集群。复制因子为 3，ISR 为 2。

此外，还有一个生成消息的生产者服务（运行 Spring 流）和一个从主题读取消息的消费者服务。现在我尝试用滚动更新的方式更新Kafka集群，希望不会出现停机，但是在更新过程中，生产者的日志中充满了这个错误：

org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition.

根据我的计算，当 1 个代理宕机时，应该不会有问题，因为最小 ISR 是 2。但是，生产者服务似乎不知道滚动更新并继续向同一个代理发送消息......

有什么想法如何解决吗？

这是我的 kafka.yaml

apiVersion: apps/v1beta1
kind: StatefulSet
metadata:
  name: kafka
  namespace: default
  labels:
    app: kafka
spec:
  serviceName: kafka
  replicas: 4
  updateStrategy:
    type: RollingUpdate
  template:
    metadata:
      labels:
        app: kafka
      annotations:
        prometheus.io/scrape: "true"
        prometheus.io/port: "9308"
    spec:
      nodeSelector:
        middleware.node: "true"
      imagePullSecrets:
      - name: nexus-registry
      terminationGracePeriodSeconds: 300
      containers:
      - name: kafka
        image: kafka:2.12-2.1.0
        imagePullPolicy: IfNotPresent …

我如何计算我的 Kafka 集群需要多少内存和 CPU？我的集群由 3 个节点组成，吞吐量约为每秒 800 条消息。

目前他们有（每个）6 GB ram，2 CPU，1T 磁盘，似乎还不够。你会分配多少？

我正在使用操作系统 10.13.6 的 Mac。

我想将从我的计算机发出的所有请求重定向到 10.20.154.24:1111 转到 localhost:8080。

我读过有关 pf 和 pfctl 的内容，但无法使其工作。

我想运行这个，但它不起作用......

echo "
rdr pass inet proto tcp from 127.0.0.1 to 10.20.154.24 port 1111 -> 127.0.0.1 port 8080
" | sudo pfctl -ef -

我@Size在Spring控制器中看到了注释作为限制.我正在寻找一个大小究竟是什么的解释,我发现了这个:

将评估字段或属性的大小,并且必须与指定的边界匹配.如果字段或属性是String,则计算字符串的大小.如果字段或属性是Collection,则计算Collection的大小.如果字段或属性是Map,则评估Map的大小.如果字段或属性是数组,则计算数组的大小.使用可选的max或min元素之一来指定边界.

但是我不清楚你如何计算String的大小.它的字符数是多少？是字节数吗？有人知道吗？

目前，我通过@Value注入我的应用程序属性，并且效果很好。现在，我希望我的应用程序支持多个配置，这意味着其@Value每次应返回不同的值。

我阅读了有关Spring配置文件的内容，但我不明白如何在运行时切换配置文件。可能吗？

我真正需要的是在服务器启动时加载所有配置，并在请求到达时动态选择其配置文件-每个请求都应具有一组配置。