0
昨日までPub/Subトピックにメッセージを正常に公開できました。しかし、今日の朝から、コードは出版中に永遠に吊るされています。私の問題はhereと同じです。 は、それから私はtopicAdminClient.createTopicで再びハングしているGCP Pub/Sub Java APIの使用中にパブリッシャープロセスが永久にハングする
TopicName topic = TopicName.create(projectId, topicId);
try {
TopicAdminClient topicAdminClient = TopicAdminClient.create();
topicAdminClient.createTopic(topic); //HANG FOREVER
}catch(Exception e){
e.printStackTrace();
}
コード以下のコードスニペットに説明するようにするJava APIを使用してトピックを作成しようとしました。
com.google.cloud.pubsub.v1.TopicAdminClientと一緒にGCP Pub/Subのcom.google.pubsub.v1パッケージを使用しています。私はデフォルトの認証資格情報でGOOGLE_APPLICATION_CREDENTIALとと設定してみました。サービスアカウントキー。私はどこが間違っているのか分かりません。誰も私がこの問題を解決するのを助けることができますか？私は、データストアのJava APIを実行しようとした 、それがシームレスに実行されます。publishMessageは、追加情報
private static ApiFuture<String> publishMessage(Publisher publisher, ByteString message)
throws Exception {
// convert message to bytes
PubsubMessage pubsubMessage =
PubsubMessage.newBuilder().setData(message).build();
return publisher.publish(pubsubMessage);
}
以下のように定義されているメッセージを公開する
私のコードは
FileInputStream fis = new FileInputStream(new File("JSON file path"));
ApiFuture<String> messageId = publishMessage(publisher,
ByteString.copyFrom(IOUtils.toByteArray(fis)));
以下の通りです。たぶん、問題は私が推測するPubsubとだけです。