mvn clean generate-sources
Start the containers docker-compose up -d
SSH to the Tools container
docker exec -it tools /bin/bash
Run the following command to create the topic example_topic.
kafka-topics --bootstrap-server kafka1:9092 --partitions 2 --create --topic example_topic
Stop the containers docker-compose down
Delete all the volumes docker volume rm $(docker volume ls -q)
SSH to the KSQL-DB CLI container docker exec -it ksqldb-cli /bin/bash
Connect to the KSQL-CLI server ksql http://ksqldb-server:8088
Write your UDFs in the KSQL-UDFs Project.
mvn clean package
Copy the jar with dependency in target into the extensions folder