小编lan*_*lan的帖子

使用node-rdkafka重新连接到Kafka是缓慢且不一致的

我有kafka和zookeeper在一些本地docker容器中运行.

我有一个node.js代码库,它使用node-rdkafka作为消费者连接到kafka.我们称这个代码库为"消费者"

消费者使用此处显示的代码连接到kafka:https: //github.com/Blizzard/node-rdkafka/blob/master/examples/consumer-flow.md

尝试连接到现有的Kafka实例时,我得到以下输出:

consumer ready.{"name":"rdkafka#consumer-1"}
Run Code Online (Sandbox Code Playgroud)

但是接收和处理消息的代码永远不会触发,或者在开始触发之前需要几分钟(有时显然是5到10分钟).

为了确保信息正在生产,我用的脚本kafka-console-consumer.sh与卡夫卡前来旁听的消息流.果然,PLENTY数据即将到来.

似乎连接有时会失败,有时需要很长时间才能连接.

这是这段时间内的kafka日志:

kafka_1      | [2017-04-27 20:55:37,963] INFO [Group Metadata Manager on Broker 1001]: Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
kafka_1      | [2017-04-27 20:55:48,576] WARN Attempting to send response via channel for which there is no open connection, connection id 1 (kafka.network.Processor)
kafka_1      | [2017-04-27 20:55:53,185] INFO [GroupCoordinator 1001]: Preparing to restabilize group video-caption-consumer with old generation 24 (kafka.coordinator.GroupCoordinator)
kafka_1      | [2017-04-27 20:56:18,577] …
Run Code Online (Sandbox Code Playgroud)

node.js apache-kafka

5
推荐指数
1
解决办法
1079
查看次数

在 Jest 上模拟 react-native-async-storage

我正在测试依赖于 的函数@react-native-community/async-storage,所以显然我的测试必须模拟该库。

所以我在我的内部这样做jestSetupFile.js

import mockAsyncStorage from '@react-native-community/async-storage/jest/async-storage-mock';
jest.mock('@react-native-community/async-storage', () => mockAsyncStorage);
Run Code Online (Sandbox Code Playgroud)

这是来自https://github.com/react-native-community/react-native-async-storage/blob/master/docs/Jest-integration.md 的直接指令

但是,导出的文件有type关键字,我的 JavaScript 环境无法解析:

  ? Test suite failed to run

    /Users/someuser/myprojects/myproject/node_modules/@react-native-community/async-storage/jest/async-storage-mock.js:6
    type KeysType = Array<string>;
         ^^^^^^^^

    SyntaxError: Unexpected identifier
Run Code Online (Sandbox Code Playgroud)

果然,当我检查该async-storage-mock.js路径中的文件时,它包含type关键字,我认为这是导致此问题的根本原因。

我在这里做错了什么?

jestjs react-native asyncstorage

4
推荐指数
1
解决办法
2492
查看次数

当data-sly-test评估为false时保留子元素?

检查这个

<a href="${mybean.href}" data-sly-test="${mybean.href}">
  <img src="myimage.jpg" />
</a>
Run Code Online (Sandbox Code Playgroud)

我们需要的

当data-sly-test =“ $ {mybean.href}”计算为false时,仅隐藏锚标记,而不隐藏其子元素。默认行为是,当锚标记消失时,img标记也会消失。我们只想隐藏包装标签。

我希望这样的参数

<a href="${mybean.href}" data-sly-test="${mybean.href @ hideChildren=false}">
  <img src="myimage.jpg" />
</a>
Run Code Online (Sandbox Code Playgroud)

sling aem sightly htl

2
推荐指数
1
解决办法
290
查看次数

标签 统计

aem ×1

apache-kafka ×1

asyncstorage ×1

htl ×1

jestjs ×1

node.js ×1

react-native ×1

sightly ×1

sling ×1