为什么Spring云数据流教程没有显示预期结果
为什么Spring云数据流教程没有显示预期结果
提问于 2020-10-05 17:06:04
我正在尝试完成第一个教程，但在本教程中我没有得到这个结果。
https://dataflow.spring.io/docs/stream-developer-guides/streams/
本教程让我将curl用于http源，并在日志接收器中看到带有stdout文件尾的结果。
我看不出结果。我在日志中看到了启动。
我尾随日志停靠程序exec -it跳尾-f /path/from/stdout/textbox/in/dashboard
我输入curl http://localhost:20100 -H“内容-类型:文本/普通”-d“快乐流”
我只看到
2020-10-05 16:30:03.315 INFO 110 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka version : 2.0.1
2020-10-05 16:30:03.316 INFO 110 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId : fa14705e51bd2ce5
2020-10-05 16:30:03.322 INFO 110 --- [ main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService
2020-10-05 16:30:03.338 INFO 110 --- [ main] s.i.k.i.KafkaMessageDrivenChannelAdapter : started org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter@106faf11
2020-10-05 16:30:03.364 INFO 110 --- [container-0-C-1] org.apache.kafka.clients.Metadata : Cluster ID: 2J0QTxzQQmm2bLxFKgRwmA
2020-10-05 16:30:03.574 INFO 110 --- [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 20041 (http) with context path ''
2020-10-05 16:30:03.584 INFO 110 --- [ main] o.s.c.s.a.l.s.k.LogSinkKafkaApplication : Started LogSinkKafkaApplication in 38.086 seconds (JVM running for 40.251)
2020-10-05 16:30:05.852 INFO 110 --- [container-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-3, groupId=http-ingest] Discovered group coordinator kafka-broker:9092 (id: 2147482646 rack: null)
2020-10-05 16:30:05.857 INFO 110 --- [container-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-3, groupId=http-ingest] Revoking previously assigned partitions []
2020-10-05 16:30:05.858 INFO 110 --- [container-0-C-1] o.s.c.s.b.k.KafkaMessageChannelBinder$1 : partitions revoked: []
2020-10-05 16:30:05.858 INFO 110 --- [container-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-3, groupId=http-ingest] (Re-)joining group
2020-10-05 16:30:08.943 INFO 110 --- [container-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-3, groupId=http-ingest] Successfully joined group with generation 1
2020-10-05 16:30:08.945 INFO 110 --- [container-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-3, groupId=http-ingest] Setting newly assigned partitions [http-ingest.http-0]
2020-10-05 16:30:08.964 INFO 110 --- [container-0-C-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=consumer-3, groupId=http-ingest] Resetting offset for partition http-ingest.http-0 to offset 0.
2020-10-05 16:30:08.981 INFO 110 --- [container-0-C-1] o.s.c.s.b.k.KafkaMessageChannelBinder$1 : partitions assigned: [http-ingest.http-0]没有快乐流
有什么建议吗？
回答 1
Stack Overflow用户
回答已采纳
发布于 2020-10-05 23:18:43
谢谢您试用开发指南！
据我所知，SCDF中的http | log流定义是在没有显式端口的情况下提交的。在这种情况下，当http-source和log-sink应用程序启动时，由Spring随机分配端口。
如果您导航到您的http-source应用程序日志，您将看到列出的应用程序端口，这就是您在CURL命令上使用的端口。
关于这一点，在指南中有以下注意事项，供您参考。
如果使用本地数据流服务器，请添加以下部署属性以设置端口以避免端口冲突。
或者，您可以在定义中使用显式端口部署流。例如：http --server.port=9004 | log。这样，你的卷发就会是：
curl http://localhost:9004 -H“内容类型:文本/普通”-d“快乐流”
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/64213177
复制相关文章
相似问题
腾讯云开发者
