This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new cfa1c60c2 Google Cloud Pub/Sub: drop unmaintained prep image,
provision emulator via REST (#1900)
cfa1c60c2 is described below
commit cfa1c60c269147d1a3a9618e75787a1428450997
Author: PJ Fanning <[email protected]>
AuthorDate: Fri Sep 4 09:48:59 2026 +0100
Google Cloud Pub/Sub: drop unmaintained prep image, provision emulator via
REST (#1900)
* Google Cloud Pub/Sub: drop unmaintained prep image, provision emulator
via REST
* avoid docker compose variable interpolation in prep command
---
docker-compose.yml | 26 +++++++++++++++-----------
1 file changed, 15 insertions(+), 11 deletions(-)
diff --git a/docker-compose.yml b/docker-compose.yml
index d698cf9f0..11b22a28e 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -94,20 +94,24 @@ services:
- "8538:8538"
command: gcloud beta emulators pubsub start --project=pekko-connectors
--host-port=0.0.0.0:8538
gcloud-pubsub-emulator_prep:
- image: martynas/gcloud-pubsub-client
+ # same image as the emulator itself; creates the topics and subscriptions
+ # the tests expect, via the emulator's REST API
+ image: google/cloud-sdk:554.0.0
links:
- "gcloud-pubsub-emulator"
- environment:
- - "PUBSUB_PROJECT_ID=pekko-connectors"
- - "PUBSUB_EMULATOR_HOST=gcloud-pubsub-emulator:8538"
entrypoint: ""
- command: >
- bash -c "
- python publisher.py pekko-connectors create simpleTopic &&
- python subscriber.py pekko-connectors create simpleTopic
simpleSubscription
- python publisher.py pekko-connectors create testTopic &&
- python subscriber.py pekko-connectors create testTopic testSubscription
- "
+ command:
+ - bash
+ - -c
+ - |
+ set -ex
+ until curl -s --fail
http://gcloud-pubsub-emulator:8538/v1/projects/pekko-connectors/topics >
/dev/null; do
+ sleep 2
+ done
+ curl -s --fail -X PUT
http://gcloud-pubsub-emulator:8538/v1/projects/pekko-connectors/topics/simpleTopic
+ curl -s --fail -X PUT -H "Content-Type: application/json" -d
'{"topic": "projects/pekko-connectors/topics/simpleTopic"}'
http://gcloud-pubsub-emulator:8538/v1/projects/pekko-connectors/subscriptions/simpleSubscription
+ curl -s --fail -X PUT
http://gcloud-pubsub-emulator:8538/v1/projects/pekko-connectors/topics/testTopic
+ curl -s --fail -X PUT -H "Content-Type: application/json" -d
'{"topic": "projects/pekko-connectors/topics/testTopic"}'
http://gcloud-pubsub-emulator:8538/v1/projects/pekko-connectors/subscriptions/testSubscription
hbase:
image: harisekhon/hbase:2.1
hostname: hbase
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
