Publish and Subscribe / Process / Store
- Kafka uses ZooKeeper as a distributed backend.
//usr/bin/env jbang "$0" "$@" ; exit $? | |
//DEPS io.smallrye.reactive:smallrye-mutiny-vertx-web-client:1.1.0 | |
//DEPS io.smallrye.reactive:mutiny:0.7.0 | |
//DEPS org.slf4j:slf4j-nop:1.7.30 | |
package io.vertx.mutiny.pagination; | |
import io.smallrye.mutiny.Multi; | |
import io.smallrye.mutiny.Uni; |
echo "start `date`" | |
# Get the directory of the currently running script | |
script_dir=$(dirname "$0") | |
# Change the working directory to the directory of the script | |
cd "$script_dir" | |
echo `pwd` |