springxd计数器不与kafka源一起工作

zpqajqem  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(291)

我使用的是springxd1.3和apachekafka 0.9.0.0。
我有一个功能正常的kafka生产者,我可以在springxd中将其配置为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' ),当我尝试使用“counter list”命令列出计数器时,此计数器不显示。
我从文档中尝试了twittersearch反例,效果很好。
问题:是否缺少配置/设置步骤?为什么我自己的柜台在这种情况下不起作用?
(仅供参考kafka和springxd都在dev/单节点模式下运行)

pod7payv

pod7payv1#

只是为了确认 counter list 仅当计数器中至少有一个值时才显示特定计数器。
您确定至少有一条消息可能被计数器接收到吗?
还有,当你这么做的时候 stream list 你看到小溪了吗 metrics1tap1 在那里?

相关问题