我正在学习如何将pubsub与elasticsearch集成。有各种选项,例如pubsubbeatGoogle_pubsub input pluginGoogle Cloud Pub/Sub Output Plugin

我目前正在按照建议运行命令“ ./pubsubbeat -c pubsubbeat.yml -e -d“ *”“后尝试使用pubsubbeat并卡住。控制台的日志如下

2019-05-23T14:42:19.949+0100    INFO    instance/beat.go:468    Home path: [/home/amishra/pubsubbeat-linux-amd64] Config path: [/home/amishra/pubsubbeat-linux-amd64] Data path: [/home/amishra/pubsubbeat-linux-amd64/data] Logs path: [/home/amishra/pubsubbeat-linux-amd64/logs]
2019-05-23T14:42:19.949+0100    DEBUG   [beat]  instance/beat.go:495    Beat metadata path: /home/amishra/pubsubbeat-linux-amd64/data/meta.json
2019-05-23T14:42:19.949+0100    INFO    instance/beat.go:475    Beat UUID: 4bd6119e-603a-426c-9d5b-6ac588bb000e
2019-05-23T14:42:19.949+0100    INFO    instance/beat.go:213    Setup Beat: pubsubbeat; Version: 6.2.2
2019-05-23T14:42:19.949+0100    DEBUG   [beat]  instance/beat.go:230    Initializing output plugins
2019-05-23T14:42:19.949+0100    DEBUG   [processors]    processors/processor.go:49  Processors:
2019-05-23T14:42:19.952+0100    INFO    pipeline/module.go:76   Beat name: allspark
2019-05-23T14:42:19.952+0100    INFO    [PubSub: dev/elk-logstash-poc/logstash-poc] beater/pubsubbeat.go:54 config retrieved: &{Project:dev Topic:elk-logstash-poc CredentialsFile:/home/amishra/key/key.json Subscription:{Name:logstash-poc RetainAckedMessages:false RetentionDuration:5h0m0s} Json:{Enabled:false AddErrorKey:false}}


再次考虑,我尝试了解决方案2,但遇到错误并无法解决

io.grpc.internal.ManagedChannelImpl$NameResolverListenerImpl onError
WARNING: [io.grpc.internal.ManagedChannelImpl-1] Failed to resolve name. status=Status{code=UNAVAILABLE, description=Unable to resolve host pubsub.googleapis.com, cause=java.net.UnknownHostException: pubsub.googleapis.com


如何使事物正常工作的任何线索都会有很大帮助

最佳答案

该问题以意外的方式得到解决,即在新计算机上安装和部署。根本原因仍然未知。

07-24 21:22