Gcp pubsub input error

Elastic Stack Logstash
1

Logstash 8.3.3, having this error with gcp pubsub input. Trying with basic settings.

[2022-08-17T22:52:45,136][ERROR][logstash.javapipeline    ][main][69466b68efba17b190dd16bcd12466cd5488773b860c9a0f79fa6c7c65f5ec61] A plugin had an unrecoverable error. Will restart this plugin.
  Pipeline_id:main
  Plugin: <LogStash::Inputs::GooglePubSub json_key_file=>"/Users/gustavollermalylarrain/Downloads/logstash-8.2.2/pkey.json", topic=>"slm", subscription=>"slm-sub", id=>"69466b68efba17b190dd16bcd12466cd5488773b860c9a0f79fa6c7c65f5ec61", project_id=>"cosmic-keep-148903", enable_metric=>true, codec=><LogStash::Codecs::Plain id=>"plain_39a662bf-b86e-4054-bf09-edc8c0d8f9ae", enable_metric=>true, charset=>"UTF-8">, max_messages=>5, include_metadata=>false, create_subscription=>false>
  Error: Expected the service InnerService [FAILED] to be TERMINATED, but the service has FAILED
  Exception: Java::JavaLang::IllegalStateException
  Stack: com.google.common.util.concurrent.AbstractService.checkCurrentState(com/google/common/util/concurrent/AbstractService.java:381)
com.google.common.util.concurrent.AbstractService.awaitTerminated(com/google/common/util/concurrent/AbstractService.java:338)
com.google.api.core.AbstractApiService.awaitTerminated(com/google/api/core/AbstractApiService.java:104)
jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
jdk.internal.reflect.NativeMethodAccessorImpl.invoke(jdk/internal/reflect/NativeMethodAccessorImpl.java:62)
jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(jdk/internal/reflect/DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(java/lang/reflect/Method.java:566)
org.jruby.javasupport.JavaMethod.invokeDirectWithExceptionHandling(org/jruby/javasupport/JavaMethod.java:441)
org.jruby.javasupport.JavaMethod.invokeDirect(org/jruby/javasupport/JavaMethod.java:305)
Users.gustavollermalylarrain.Downloads.logstash_minus_8_dot_3_dot_3.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_input_minus_google_pubsub_minus_1_dot_2_dot_1.lib.logstash.inputs.google_pubsub.run(/Users/gustavollermalylarrain/Downloads/logstash-8.3.3/vendor/bundle/jruby/2.5.0/gems/logstash-input-google_pubsub-1.2.1/lib/logstash/inputs/google_pubsub.rb:277)
Users.gustavollermalylarrain.Downloads.logstash_minus_8_dot_3_dot_3.logstash_minus_core.lib.logstash.java_pipeline.inputworker(/Users/gustavollermalylarrain/Downloads/logstash-8.3.3/logstash-core/lib/logstash/java_pipeline.rb:410)
Users.gustavollermalylarrain.Downloads.logstash_minus_8_dot_3_dot_3.logstash_minus_core.lib.logstash.java_pipeline.start_input(/Users/gustavollermalylarrain/Downloads/logstash-8.3.3/logstash-core/lib/logstash/java_pipeline.rb:401)
org.jruby.RubyProc.call(org/jruby/RubyProc.java:318)
java.lang.Thread.run(java/lang/Thread.java:829)
[2022-08-17T22:52:46,160][ERROR][logstash.inputs.googlepubsub][main][69466b68efba17b190dd16bcd12466cd5488773b860c9a0f79fa6c7c65f5ec61] Expected the service InnerService [FAILED] to be RUNNING, but the service has FAILED
Aug 17, 2022 10:52:46 PM com.google.common.util.concurrent.ListenerCallQueue$PerListenerQueue run
SEVERE: Exception while executing callback: com.google.api.core.AbstractApiService$1@7bf32335 failed({from = STARTING, cause = java.lang.IllegalStateException: Expected the service InnerService [FAILED] to be RUNNING, but the service has FAILED})
java.lang.IllegalStateException: Expected the service InnerService [FAILED] to be RUNNING, but the service has FAILED
        at com.google.common.util.concurrent.AbstractService.checkCurrentState(AbstractService.java:381)
        at com.google.common.util.concurrent.AbstractService.awaitRunning(AbstractService.java:305)
        at com.google.api.core.AbstractApiService.awaitRunning(AbstractApiService.java:96)
        at com.google.cloud.pubsub.v1.Subscriber.startConnections(Subscriber.java:390)
        at com.google.cloud.pubsub.v1.Subscriber.startStreamingConnections(Subscriber.java:355)
        at com.google.cloud.pubsub.v1.Subscriber.access$200(Subscriber.java:93)
        at com.google.cloud.pubsub.v1.Subscriber$3.run(Subscriber.java:299)
        at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: java.lang.NoSuchMethodError: 'void com.google.common.util.concurrent.Futures.addCallback(com.google.common.util.concurrent.ListenableFuture, com.google.common.util.concurrent.FutureCallback)'
        at com.google.cloud.pubsub.v1.StreamingSubscriberConnection.initialize(StreamingSubscriberConnection.java:218)
        at com.google.cloud.pubsub.v1.StreamingSubscriberConnection.doStart(StreamingSubscriberConnection.java:110)
        at com.google.api.core.AbstractApiService$InnerService.doStart(AbstractApiService.java:148)
        at com.google.common.util.concurrent.AbstractService.startAsync(AbstractService.java:251)
        at com.google.api.core.AbstractApiService.startAsync(AbstractApiService.java:120)
        at com.google.cloud.pubsub.v1.Subscriber.startConnections(Subscriber.java:387)
        ... 4 more
2

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.