小编Jav*_*era的帖子

我正在使用Windows Server 2012和IIS 8.5.我为网站设置了SSL,SSL设置为:Require Required and Require Client Certificates.

我发送给服务器的客户端证书是由自签名权限发出的(我们称之为MyCompany CA).MyCompany CA证书已成功安装在本地计算机帐户 - 受信任的根证书颁发机构中.它的到期日期是2039,客户端证书的到期日期也是如此.

但是,通过所有这些设置,我收到错误403.16作为结果.我启用了失败请求跟踪规则并设法记录错误请求并获得了一些额外的详细信息:

52.- MODULE_SET_RESPONSE_ERROR_STATUS - 警告ModuleName - IIS Web核心通知 - BEGIN_REQUEST HttpStatus - 403 HttpReason - 禁止HttpSubStatus - 16 ErrorCode - 已处理证书链,但终止于信任提供程序不信任的根证书.(0x800b0109)ConfigExceptionInfo

我已经检查了多个关于结果403.16和错误代码0x800b0109的站点,并且所有站点都指向未在本地计算机 - 受信任的根证书颁发机构中安装的证书颁发机构,但这不是我的情况.

谢谢!

我有一个看起来像这样的管道：

jobs:
- name: master
  public: true
  plan:
  - get: master-git
    trigger: true
  - get: my-build-image
  - task: "Run integration tests"
    image: my-build-image
    privileged: true
    config:
      platform: linux
      inputs:
      - name: master-git
      outputs:
      - name: build-workspace
      run:
        dir: master-git
        path: make
        args:
        - ci

'my-build-image'是一个docker映像，它具有一个入口点，该入口点使用https://github.com/progrium/entrykit在运行提供的任何命令之前先运行一些命令。

问题似乎是，当Concourse（或Garden）使用my-build-image运行docker容器时，它覆盖了入口点，因为这些命令似乎不再执行了。

我正在尝试使用Concourse（使用docker-compose）进行本地部署，因此我可以访问所有设置。但是，我对Concourse还是很陌生，所以我不确定在哪里可以找到日志和类似内容。

查看文档，我不确定我是否理解使用close()和lush()之间的区别。

这是flush()的文档

 * Invoking this method makes all buffered records immediately available to send (even if <code>linger.ms</code> is
 * greater than 0) and blocks on the completion of the requests associated with these records. The post-condition
 * of <code>flush()</code> is that any previously sent record will have completed (e.g. <code>Future.isDone() == true</code>).
 * A request is considered completed when it is successfully acknowledged
 * according to the <code>acks</code> configuration you have specified or else it results …

Run Code Online (Sandbox Code Playgroud)

Apache Kafka文档说明:

内部Kafka Streams使用者max.poll.interval.ms默认值已从300000更改为Integer.MAX_VALUE

由于此值用于检测一批记录的处理时间何时超过给定阈值,是否存在这种"无限"值的原因？

它是否使应用程序无响应？或者,当处理时间过长时,Kafka Streams有不同的方式离开消费者群体？

我正在尝试构建以下拓扑：

1. 使用 Debezium 连接器，我拉了 2 个表（我们称它们为表 A 和 DA）。根据 DBZ，存储表行的主题具有结构 { before: "...", after: "..." }。

2. 我的拓扑的第一步是从这两个“表”主题创建“干净的”KStreams。那里的子拓扑大致如下所示：

private static KStream<String, TABLE_A.Value> getTableARowByIdStream(
    StreamsBuilder builder, Properties streamsConfig) {
  return builder
      .stream("TABLE_A", Consumed.withTimestampExtractor(Application::getRowDate))
      .filter((key, envelope) -> [ some filtering condition ] )
      .map((key, envelope) -> [ maps to TABLE_A.Value ] )
      .through(tableRowByIdTopicName);
}

3. 请注意，我明确分配了记录时间，因为表行在最初发布后将被 CDC 标记为“年”。该函数目前正在做的是伪造从 2010-01-01 开始的时间，并使用AtomicInteger为每个消耗的实体添加 1 毫秒。它对表 A 执行此操作，但对 DA 不执行此操作（稍后我将解释原因）。

4. 拓扑的第 2 阶段是基于表 A 的“已清理”主题构建 1 个 KTable，如下所示：

private static KTable<String, EntityInfoList> getEntityInfoListById(
    KStream<String, TABLE_A.Value> tableAByIdStream) …