小编Sib*_*ain的帖子

我对Kubernetes很新,并想用它设置Kafka和zookeeper.我能够使用StatefulSets在Kubernetes中设置Apache Kafka和Zookeeper.我按照这个和这个来构建我的清单文件.我制作了1张kafka和zookeeper的复制品,并且还使用了持久卷.所有pod都在运行并准备就绪.

我试图Service通过指定nodePort(30010)来公开kafka并将其用于此目的.看起来这会将kafka暴露给外面的世界,在那里他们可以向kafka经纪人发送消息并从中消费.

但是在我的Java应用程序中,我创建了一个使用者并添加了bootstrapServer <ip-address>:30010,显示了以下日志:

INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator kafka-0.kafka-hs.default.svc.cluster.local:9093 (id: 2147483647 rack: null) for group workerListener.
INFO o.a.k.c.c.i.AbstractCoordinator - Marking the coordinator kafka-0.kafka-hs.default.svc.cluster.local:9093 (id: 2147483647 rack: null) dead for group workerListener

有趣的是,当我使用kubectl命令测试集群时,我能够生成和使用消息:

kubectl run -ti --image=gcr.io/google_containers/kubernetes-kafka:1.0-10.2.1 produce --restart=Never --rm \
 -- kafka-console-producer.sh --topic test --broker-list kafka-0.kafka-hs.default.svc.cluster.local:9093 done;

kubectl run -ti --image=gcr.io/google_containers/kubernetes-kafka:1.0-10.2.1 consume --restart=Never --rm -- kafka-console-consumer.sh --topic test --bootstrap-server kafka-0.kafka-hs.default.svc.cluster.local:9093

有人能指出我正确的方向为什么它将协调员标记为死亡？

kafka.yml

apiVersion: v1
kind: Service
metadata:
  name: kafka-hs …

我有几个 AWS Lambda 函数。所有这些函数都使用一些常见的辅助函数。我将这些辅助函数放在一个名为helper_functions.py. 我想在我所有的 AWS Lambda 函数中导入这个模块。我找不到存储此模块 ( helper_functions.py) 的位置，因此当我更改此模块时，我无需更改我的 Lambda 函数中的任何内容。

我想到的一些选项是：

1. 在 AWS S3 上上传模块，然后从 S3 开始将其加载到每个 Lambda 函数中并使用这些函数。（如果可能的话）

2. 编写一些脚本（我还没有弄清楚），将模块与 Lambda 函数的 Python 文件一起打包到一个 zip 文件中，并将其上传到 AWS Lambda

请提出一个更好的解决方案来管理模块并以更有效的方式导入它。

我在AWS API Gateway中创建了一个调用Lambda函数的API.这是我用来返回几乎类似于Python Lambda Blueprint的application/json响应的代码:

def response(status_code, response_body=None):
    return {
        'statusCode': status_code,
        'body': json.dumps(response_body) if response_body else json.dumps({}),
        'headers': {
            'Content-Type': 'application/json',
        },
    }

目前我只有一个HTTP状态代码200.我很难为这个响应制作模型模式.

如何让身体摆脱这种反应并将其正确显示给消费者？

编辑: 我需要使用Lambda代理集成创建我的API,因为在这里我从Lambda返回响应而根本不转换它.此外,这里不需要模型架构.有关详细信息,请阅读接受的答案.

注意:为避免请求的资源上没有"Access-Control-Allow-Origin"标头.错误.只需添加'Access-Control-Allow-Origin': '*'标题即可Content-Type

干杯!

我想创建一个秒表.我用Google搜索并获得了一些关于如何制作计时器的提示.这是我在我的控制器中所做的:

$scope.value = 0;
$scope.startTimer = function() {

     $scope.value = 0;

    var change = function() {
        $scope.value += 1000;
        $timeout(change,1000);
    };
    $timeout(change, 1000);
}

并以我的html显示的格式为这种格式:

<label>{{value | date: 'hh:mm:ss'}}</label>

问题是时钟始终在04:00:00开始,当我调用该startTimer()函数时,它启动计时器没问题,但我希望计时器如下:

00:00:00

00:00:01

00:00:02

....

谁能告诉我如何在00:00:00启动计时器？

我想在python中创建一个jira问题.我知道如何设置摘要,问题类型,描述和项目名称,但我找不到如何设置优先级,截止日期,环境和其他字段.

这就是我所知道的:

new_issue = jira.create_issue(project={'key': 'key'}, summary='New issue from jira-   python',   description='Look into this one', issuetype={'name': 'Bug'})

如何设置其他字段？

我正在使用 Amazon SNS 在 HTTP/HTTPS 终端节点上接收推送消息。端点应用程序是用 Django 编写的。要在端点（Web 应用程序）上接收通知，HTTP/HTTPS 端点需要订阅主题。

订阅后，Amazon SNS 会向指定 URL 发送 HTTP POST 请求，需要通过检索 HTTP POST 请求标头中的参数来确认订阅。

我尝试使用 Google Chrome 扩展程序Postman通过在我的 url 上发送 POST 请求，但它给出了CSRF token error.

我的问题是，当 Amzaon SNS 发送订阅确认时，它如何在 POST 请求中发送 CSRF 令牌，以便我可以处理请求并检索所需的信息？

文档：http://docs.aws.amazon.com/sns/latest/dg/SendMessageToHttp.html

我正在尝试使用特定定义中的模板参数获取所有正在运行的构建（正在进行中）+。我正在 Azure DevOps 中使用 Powershell@2 任务来完成此任务，但多个条件未使用Where-Object 运行。下面是代码：

$token = "123"
$organization = "foo"
$project = "abc"

$base64AuthInfo = [Convert]::ToBase64String([Text.Encoding]::ASCII.GetBytes(("{0}:{1}" -f $user,$token)))

$ThisBuildDefinitionID = "8430"
[int]$ThisBuildID = "1571327"


$GET_BUILDS_BY_DEFINITION_URL = "https://azure.com/$organization/$project/_apis/build/builds?api-version=6.0&definitions=$ThisBuildDefinitionID"

do
{
    $GET_BUILDS_BY_DEFINITION_RESPONSE = ""
    try
    {
      $GET_BUILDS_BY_DEFINITION_RESPONSE = Invoke-RestMethod -Uri $GET_BUILDS_BY_DEFINITION_URL `
                                  -Method GET `
                                  -ContentType "application/json" `
                                  -Headers @{Authorization=("Basic {0}" -f $base64AuthInfo)}
    }
    catch
    {
      continue
    }
    
    Write-Host $GET_BUILDS_BY_DEFINITION_RESPONSE.value
    
    [array]$runningBuilds = $GET_BUILDS_BY_DEFINITION_RESPONSE.value | Where-Object {"status" -eq "inProgress" -and "templateParameters.param1" -eq "myparam"}

    Write-Host "running builds count: " $runningBuilds.count
    if …

我有一个列表视图,想要从中搜索文本.我已成功完成,但现在我想搜索项目并在列表视图中突出显示搜索到的文本.这是我在ListViewAdapter中的过滤器函数:

public void filter(String charText) {

    charText = charText.toLowerCase(Locale.getDefault());
    worldpopulationlist.clear();
    if (charText.length() == 0) {
        worldpopulationlist.addAll(arraylist);
    } 
    else 
    {
        for (WorldPopulation wp : arraylist) 
        {
            // Find charText in wp
            int startPos = wp.getCountry().toLowerCase(
                    Locale.getDefault()).indexOf(charText.toLowerCase(Locale.getDefault()));
            int endPos = startPos + charText.length();
            if (startPos != -1) 
            {
                   Spannable spannable = new SpannableString(wp.getCountry());
                    ColorStateList blueColor = new ColorStateList(new int[][] { new int[] {}}, new int[] { Color.BLUE });
                    TextAppearanceSpan highlightSpan = new TextAppearanceSpan(null, Typeface.BOLD, -1, blueColor, null);

                    spannable.setSpan(highlightSpan, startPos, endPos, Spannable.SPAN_EXCLUSIVE_EXCLUSIVE);
                   // …