This is a demo project for Ingest-Materialize-Index stream topology/architecture, as presented at Confluent Current in New Orleans in 2025.
This application demos the following architecture:
You can view a demo video (as presented at Confluent Current '25 in New Orleans) here.
This project is a runnable Spring Boot application. The following instructions show how to execute it:
The following prerequisites must be satisfied in order to run this project:
- JDK 1.8 or higher installed
- Docker running locally
- In order to run some resources locally (i.e. AWS Localstack), Docker is needed
You can run this application by simply executing the following:
./mvnw spring-boot:runYou can use the following curl commands to illustrate the purpose of this demo:
curl --location 'http://localhost:8080/companyCreatedEvents' \
--header 'Content-Type: application/json' \
--data '{
"companyId": "1",
"companyName": "Confluent"
}'curl --location 'http://localhost:8080/hiringIntentCreatedEvents' \
--header 'Content-Type: application/json' \
--data '{
"hiringIntentId": "1",
"companyId": "1",
"jobTitle": "Software Engineer",
"jobDescription": "Stream all the things!"
}'You should see "views" produced (logged) that look like the following:
{
"hiringIntentId" : "1",
"companyName" : "Confluent",
"jobTitle" : "Software Engineer",
"jobDescription" : "Stream all the things!"
}