diff --git a/docs/posts/flink-announcement/index.qmd b/docs/posts/flink-announcement/index.qmd index 980d4dc6899b..26fe28631754 100644 --- a/docs/posts/flink-announcement/index.qmd +++ b/docs/posts/flink-announcement/index.qmd @@ -66,15 +66,15 @@ pixi add ibis-flink ## Spinning up the services using Docker Compose -The [ibis-project/ibis-flink-example GitHub -repository](https://github.com/ibis-project/ibis-flink-example) includes the +The [ibis-project/realtime-fraud-detection GitHub +repository](https://github.com/ibis-project/realtime-fraud-detection) includes the relevant Docker Compose configuration for this tutorial. Clone the repository, and run `docker compose up` from the cloned directory to create Kafka topics, generate sample data, and launch a Flink cluster: ```bash -git clone https://github.com/claypotai/ibis-flink-example.git -cd ibis-flink-example +git clone https://github.com/claypotai/realtime-fraud-detection.git +cd realtime-fraud-detection docker compose up ``` @@ -88,12 +88,12 @@ After a few seconds, you should see messages indicating your Kafka environment is ready: ```bash -ibis-flink-example-init-kafka-1 | Successfully created the following topics: -ibis-flink-example-init-kafka-1 | payment_msg -ibis-flink-example-init-kafka-1 | sink -ibis-flink-example-init-kafka-1 exited with code 0 -ibis-flink-example-data-generator-1 | Connected to Kafka -ibis-flink-example-data-generator-1 | Producing 20000 records to Kafka topic payment_msg +realtime-fraud-detection-init-kafka-1 | Successfully created the following topics: +realtime-fraud-detection-init-kafka-1 | payment_msg +realtime-fraud-detection-init-kafka-1 | sink +realtime-fraud-detection-init-kafka-1 exited with code 0 +realtime-fraud-detection-data-generator-1 | Connected to Kafka +realtime-fraud-detection-data-generator-1 | Producing 20000 records to Kafka topic payment_msg ``` This example uses mock payments data. The `payment_msg` Kafka topic contains diff --git a/docs/posts/unified-stream-batch/index.qmd b/docs/posts/unified-stream-batch/index.qmd index 3d38c3894b6c..0851e5254ef5 100644 --- a/docs/posts/unified-stream-batch/index.qmd +++ b/docs/posts/unified-stream-batch/index.qmd @@ -172,7 +172,7 @@ website](https://docs.docker.com/compose/install/). * Follow [the setup tutorial](../../tutorials/open-source-software/apache-flink/0_setup.qmd) to install the Flink backend for Ibis. -* Clone the [example repository](https://github.com/ibis-project/ibis-flink-example). +* Clone the [example repository](https://github.com/ibis-project/realtime-fraud-detection). ::: ::: {.callout-note} @@ -199,8 +199,8 @@ would extract a chunk of the data and load it in batch: # | code-fold: true # | include: false !pip install apache-flink kafka-python -!git clone https://github.com/ibis-project/ibis-flink-example -!cd ibis-flink-example && docker compose up kafka init-kafka data-generator -d && sleep 10 && cd .. +!git clone https://github.com/ibis-project/realtime-fraud-detection +!cd realtime-fraud-detection && docker compose up kafka init-kafka data-generator -d && sleep 10 && cd .. ``` ```{python}