我有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) 我正在测试依赖于 的函数@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关键字,我认为这是导致此问题的根本原因。
我在这里做错了什么?
检查这个
<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) aem ×1
apache-kafka ×1
asyncstorage ×1
htl ×1
jestjs ×1
node.js ×1
react-native ×1
sightly ×1
sling ×1