0
다음과 같이 나는 가입자는 정의 : 그러나구글 Pubsub 가입자 startAsync NosuchmethodError
class PubSubMessageReceiver extends MessageReceiver {
override def receiveMessage(message: PubsubMessage, consumer: AckReplyConsumer): Unit = {
// .. business logic
//acknowledge message
consumer.ack()
}
}
val subscriber = Subscriber.defaultBuilder(subscriptionName, new PubSubMessageReceiver).build()
subscriber.startAsync
나는 다음과 같은 오류가 나타납니다 전화 :
java.lang.NoSuchMethodError: com.google.api.core.AbstractApiService$InnerService.startAsync()Lcom/google/common/util/concurrent/Service;
at com.google.api.core.AbstractApiService.startAsync(AbstractApiService.java:121)
at com.google.cloud.pubsub.spi.v1.Subscriber.startAsync(Subscriber.java:218)
가입자를 어떤 환경에서 시작하고 있습니까? –