diff --git a/demos/nifi-kafka-druid-earthquake-data/create-nifi-ingestion-job.yaml b/demos/nifi-kafka-druid-earthquake-data/create-nifi-ingestion-job.yaml index 15f2807e..f078bf87 100644 --- a/demos/nifi-kafka-druid-earthquake-data/create-nifi-ingestion-job.yaml +++ b/demos/nifi-kafka-druid-earthquake-data/create-nifi-ingestion-job.yaml @@ -76,7 +76,7 @@ data: service_login(username=USERNAME, password=PASSWORD) print("Logged in") - response = requests.get("https://raw.githubusercontent.com/stackabletech/demos/refs/heads/main/demos/nifi-kafka-druid-earthquake-data/IngestEarthquakesToKafka.json") + response = requests.get("https://raw.githubusercontent.com/stackabletech/demos/refs/heads/release-25.7/demos/nifi-kafka-druid-earthquake-data/IngestEarthquakesToKafka.json") filename = "/tmp/IngestEarthquakesToKafka.json" with open(filename, "wb") as f: f.write(response.content) diff --git a/demos/nifi-kafka-druid-water-level-data/create-nifi-ingestion-job.yaml b/demos/nifi-kafka-druid-water-level-data/create-nifi-ingestion-job.yaml index f02c6f08..a9160838 100644 --- a/demos/nifi-kafka-druid-water-level-data/create-nifi-ingestion-job.yaml +++ b/demos/nifi-kafka-druid-water-level-data/create-nifi-ingestion-job.yaml @@ -76,7 +76,7 @@ data: service_login(username=USERNAME, password=PASSWORD) print("Logged in") - response = requests.get("https://raw.githubusercontent.com/stackabletech/demos/refs/heads/main/demos/nifi-kafka-druid-water-level-data/IngestWaterLevelsToKafka.json") + response = requests.get("https://raw.githubusercontent.com/stackabletech/demos/refs/heads/release-25.7/demos/nifi-kafka-druid-water-level-data/IngestWaterLevelsToKafka.json") filename = "/tmp/IngestWaterLevelsToKafka.json" with open(filename, "wb") as f: