Confluent Cloud Apache Flink® Table API - Fraud Detection Demo

To demonstrate to bootup a Confluent Platform cluster to work with afedulov/fraud-detection-demo

📒 Pre-requisites

• fraud-detection-demo
• Docker
• Maven
• Java

🧭 Guides

Follow the guide below to bootup Confluent Platform alongside with fraud-detection-demo

Setup Confluent Cloud

You must setup Confluent Cloud Flink Table API. Access to your Confluent Cloud and perform the following steps

1️⃣ Create Cloud Environment environment named e.g fraud-detection-demo

2️⃣ Create cluster for Cloud Environment fraud-detection-demo cluster named e.g cluster_fraud_detection_demo_0

3️⃣ Generate API Key for Cloud Environment fraud-detection-demo

4️⃣ Create Flink Compute Pool for Cloud Environment fraud-detection-demo

5️⃣ Create Flink API Key for Cloud Environment fraud-detection-demo

6️⃣ Create Kafka Topic for Cloud Environment fraud-detection-demo cluster

Test Confluent Cloud Setup

Once you had done the Setup Confluent Cloud mentioned above, you can run the following JUnit Test to test your setup is proper

• Make sure your OS profile (i.e. ~/.zshrc) contains the following exported environment variable(s)

export CLOUD_PROVIDER="xxx"
export CLOUD_REGION="xxx"
export FLINK_API_KEY="xxx"
export FLINK_API_SECRET="xxx"
export ORG_ID="xxx"
export ENV_ID="xxx"
export COMPUTE_POOL_ID="xxx"

• Next, open your terminal and run the command below :

cd confluent-flink-fraud-detection-demo/fraud-detection-job
mvn test -Dtest=com.github.krakenninja.demo.confluent.cloud.HelloTableApiJUnitIntegrationTest

• You should be able to see the following result in your terminal

📚 References

• Mount Docker External Volumes in Confluent Platform
• Install Confluent Platform Using Docker
• Java Table API Quick Start on Confluent Cloud for Apache Flink