SpringXD 计数器不适用于 Kafka 源答案

【问题标题】：SpringXD counter not working with Kafka sourceSpringXD 计数器不适用于 Kafka 源
【发布时间】：2016-01-21 21:57:44
【问题描述】：

我正在使用 SpringXD 1.3 和 Apache Kafka 0.9.0.0。

我有一个正常工作的 Kafka 生产者，我可以在 Spring XD 中将其配置为 Kafka 源（我使用 Groovy 脚本在记录消息之前对其进行转换）。

stream create --name metrics1 --definition "kafka --topic=metrics | transform --script=MetricsInterpreter.groovy | log" --deploy

我可以看到我的 Kafka 消息打印在 Spring XD 日志中。所以这个流按预期工作。

但是，我创建的计数器没有显示在计数器列表中。

stream create --name metrics1tap1 --definition "tap:stream:metrics1 > counter --name=hitcount" --deploy

虽然我收到一条成功消息 (Created and deployed new stream 'metrics1tap1')，但当我尝试使用“计数器列表”命令列出计数器时，此计数器并未显示。

我尝试了文档中的 TwitterSearch 计数器示例，效果很好。

问题：我是否缺少配置/设置步骤？为什么我自己的计数器在这种情况下不起作用？

（仅供参考，Kafka 和 SpringXD 都在开发/单节点模式下运行）

【问题讨论】：

【解决方案1】：

只需确认counter list 将仅在计数器中至少有一个值时显示特定计数器。

您确定至少有一条消息可能被柜台接收到吗？

另外，当您执行stream list 时，您会在其中看到metrics1tap1 流吗？

【讨论】：