我使用的是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/单节点模式下运行)
1条答案
按热度按时间pod7payv1#
只是为了确认
counter list
仅当计数器中至少有一个值时才显示特定计数器。您确定至少有一条消息可能被计数器接收到吗?
还有,当你这么做的时候
stream list
你看到小溪了吗metrics1tap1
在那里?