小编Nag*_*sha的帖子

我已将 Kafka 提交策略设置为最新且缺少前几条消息。如果我在开始将消息发送到输入主题之前休眠 20 秒，则一切都按预期工作。我不确定问题是否与消费者花费很长时间进行分区重新平衡有关。有没有办法在开始轮询之前知道消费者是否准备好？

我们有一个带有 4 个 Pod 的应用程序，它使用负载均衡器运行！我们想尝试滚动更新，但我们不确定当 pod 出现故障时会发生什么！文档不清楚！特别是来自Termination Of Pods 的这句话：

Pod 从服务的端点列表中删除，不再被视为复制控制器的运行 Pod 集的一部分。缓慢关闭的 Pod 可以继续为流量提供服务，因为负载均衡器（如服务代理）将它们从轮换中移除。

因此，如果有人可以指导我们解决以下问题：

1.) 当 Pod 关闭时，它还能处理新的请求吗？还是负载均衡器不考虑？

2.) 它是否会在宽限期用完之前完成它正在处理的请求？然后即使有任何进程仍在运行也会杀死容器？

3.) 另外，这里提到复制控制器，我们有一个Deployment，Deployment有副本集，那么会有什么区别吗？

我们经历了这个问题，但答案是相互矛盾的，没有任何来源： Kubernetes 滚动更新是否从服务负载均衡器中优雅地删除了 pod

我们有一个docker映像和一个相应的yaml文件，用于使用kubernetes进行部署。我们构建的应用程序在带有akka-http的scala中。我们使用了akka集群。我们在使用Pod ip的应用程序代码中使用的配置文件中，有一个特定的变量（在我们的情况下为种子节点-akka群集）。但是，除非完成部署，否则我们不会获得Pod ip。我们应该如何解决这个问题？环境变量会有所帮助吗？

更具体地说，将docker映像部署在容器中的容器中之后，并且当容器启动时，容器IP已被分配。那么，在容器中开始该过程之前，我们可以通过编程方式或其他方式在代码或配置文件中配置Pod ip吗？

供参考，这是我们的配置文件：

akka {
  actor {
    provider = "akka.cluster.ClusterActorRefProvider"
  }    
  remote {
    log-remote-lifecycle-events = off
    netty.tcp {
      hostname = "127.0.0.1"
      port = 0
    }
  }
  cluster {
    seed-nodes = [
      "akka.tcp://our-system@127.0.0.1:3000",
      "akka.tcp://our-system@127.0.0.1:3001",
    ],
    metrics {
      enabled = off
    }
  }    
}
service {
  validateTokenService {
     ml.pubkey.path = "<filePath>"
  }
  ml_repository {
    url = <url address>
  }
  replication.factor = 3
  http.service.interface = "0.0.0.0"
  http.service.port = 8080
}

在上面的文件中，我们需要使用pod-ip来代替akka.remote.netty.tcp.hostname作为“ 127.0.0.1”。因此，我们可以在种子节点中将其用作：

seed-nodes = [
          "akka.tcp://our-system@hostname:3000",
          "akka.tcp://our-system@hostname:3001",
        ],

我们该怎么做？提前致谢。

我正在使用angularJs和nodejs开发应用程序。将控制器的名称设置为来自主控制器的变量的值感到震惊。为了更好地解释它，我的index.html看起来像这样：

        <tbody ng-repeat="group in groups">

        <tr ng-repeat="member in group.members" >
            <td rowspan="{{group.members.length}}" ng-hide="$index>=0">
            </td>

            <td>{{member.taskName}}</td>
            <td><div class={{group.colorMe[0]}}>{{member.env}}</div>
                <button class="btn btn-info" ng-controller="member.taskName" ng-click="test( member.taskName , 'env', group.colorMe[0])">Sanity</button>
            </td>

我的主控制器如下所示，其中组定义如下：

  var tasks =['task1','task2','task3','task4','task5'];

      for(i=0;i<tasks.length;i++)

    {

    var group = {
                  "id" : i+1,
                  "members" : [{
                      "taskName":tasks[i].toUpperCase(),
                      "env1":versionMap["env1"+tasks[i]],
                      "env2":versionMap["env2"+tasks[i]],
                      "env3":versionMap["env3"+tasks[i]]

                  }]
                };
              $scope.groups.push(group);
              }

现在，当我单击按钮时，应将我定向到特定的控制器，并且该控制器名称需要动态设置为member.taskName。有人可以帮我吗？

我的场景是这样的。

1. 我有一个由大量报告组成的向量，需要使用 REST API 调用发送。
2. 我正在使用 Futures.traverse（1中提到的向量）
3. 由于向量太大，因此会因超出最大打开请求数而失败。

我能想到的一个初步解决方案是增加 max-open-requests 设置。但这里的问题是我不知道需要提前发送多少报告。

有人可以建议一个替代解决方案，例如限制通过 Futures.traverse 发生的并行性

我是 akka-http 的新手，并在 Scala 中构建了一个基本的服务器-客户端应用程序。我查看的示例具有对象“实体”。有人可以解释一下潜在的概念，为什么使用它以及它有什么用处？

post {
    path("insert") {
      entity(as[Student]) {
        obj => complete {
          insertingstudent(obj)
          s"got obj with name ${obj.getName()}"
        }
      }

谢谢

我已经开发了一个网页,用于内部监控我公司的一些服务.我们希望记录页面上的点击次数并实时显示.我已经完成了这些问题:

确定访问网页的次数

如何使用JavaScript计算我网站上的访问者数量？

但我不能使用谷歌分析和其他此类工具.我希望它可以在nodejs中完成.问题是如果我在nodejs服务器上做这样的事情:

var express = require('express');
var app = express();

var bodyParser = require('body-parser');
var request = require('request');
var cfenv = require('cfenv');
app.use(express.static(__dirname + "/public"));
app.use(bodyParser.json());
var userCount = 0;
app.post('/counterIncrement', function(req, res){
console.log("I received a request to refresh the counter");
userCount = userCount + 1;
res.json({countNum: userCount});
});
var router1 = require('./public/routes/Route1');
router1(app);

var router2 = require('./public/routes/Route2');
router2(app);

var router3 = require('./public/routes/Route3');
router3(app);

var appEnv = cfenv.getAppEnv();

app.listen(appEnv.port, appEnv.bind, function() {

   console.log("server starting on " + appEnv.url); …

我正在使用 akka.http.scaladsl.model.HttpResponse、HttpEntity。

得到 response 后，它是格式的 responseEntity 类型 (Content-type: 'application/json', {MyJSONHERE})。有没有办法从实体中提取我的json。

我尝试了 entity.getDataBytes ，它以 ByteString 格式提供实体的内容。我想正确读取 JSON 并解析它。有人可以指导我吗？

我正在使用sweetAlert进行对话框显示.在我的对话框中,我必须显示一个大字符串,其中包含换行符.我的示例字符串如下:

var str="Task1Name          :    Success  :   statusCode\n 
         Task2NameLonger    :    Failed   :   statusCode\n"

等等.所以,基本上,我希望它们中的每一个都在一个新的行中并且空间匹配.当我使用sweetalert对话框时,换行符正确显示,但文本自动与中心对齐,间距被截断.有人可以帮我手动设置对齐和间距吗？

在继续之前，我需要检查用户是否已连接到互联网。

我正在使用 HttpClient 访问端点，如下所示：

client := &http.Client{}
req, _ := http.NewRequest("GET", url, nil)
req.SetBasicAuth(username, password)
res, err := client.Do(req)

if err != nil {
    fmt.Println(err)
    ui.Failed("Check your internet connection")
}

1) 在这种情况下，如果用户未连接到互联网，我需要向用户显示明确的消息，显示“请检查您的互联网连接”

2) 如果服务器没有响应，收到504 bad gateway，显示“504 Bad gateway”

有人可以帮助如何继续和区分这两种情况吗，我只想显示简单的消息，而不是从服务器收到的整个错误消息。

我从文件中读取了一个浮点数，并且必须将其转换为字符串。我的问题是我不确定小数点后有多少位数字。我需要准确地获取浮点数并将其转换为字符串。

For ex: 
1.10 should be converted to "1.10"
Also,
1.5 should be converted to "1.5"
Can someone suggest how to go about this?

我已经pip install <package name>将软件包安装到AppData / Python / Python36 / Scripts文件夹中。如何从命令行知道此文件夹的确切路径？

我尝试这样做py -m site --userbase 这显示了不存在的AppData / Roaming / Python / Python36。在不实际进行手动搜索的情况下，如何知道路径？

PS：我正在编写一个自动化脚本，以稍后安装pip和awscli。安装pip后，我遇到未找到命令错误。因此，寻找如何直接从脚本设置路径，而不必面对手动设置路径的问题。发现pip.exe和aws.exe在AppData / Python / Python36 / Scripts下。我的问题是如何从脚本内部获取此路径。