Publish and Subscribe / Process / Store
- Kafka uses ZooKeeper as a distributed backend.
| 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` |
| //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; |