spring cloud数据流的简单反例



我正在探索spring-cloud数据流,我可以成功地浏览twitterstream示例,字段值计数器包含一些有用的值。

但我没能创建其他简单的例子,比如:

stream create test --definition 'http --server.port=9999 | counter --name=httpcounter --store=redis' --deploy

stream create http-log --definition 'http --server.port=1234 | log' --deploy

stream create http-tap-counter --definition ':http-log.http > counter --name=http-tap-counter' --deploy

在这两种情况下,流都会被创建和部署,stream list会显示它们,但在shell中执行"计数器列表"时,计数器不会显示。

我还在日志中验证http源是否正在接收一些输入。

有什么想法吗?为什么我错过了在这里创建一个简单的计数器?

我们最近解决了counter接收器的一个问题,该修复程序现在已移植到流应用程序启动器。此修复程序也包含在最近的1.0.0.M3版本中。

请尝试最新版本,如果您仍然看到它的问题,请告诉我们。

我也遇到了同样的问题。在今天从git存储库更新了spring-cloud数据流之后,这些示例现在对我有效。

最新更新