/spring-boot-kafka

example of using kafka with spring boot - Webflux(R2DBC)

Primary LanguageKotlin

DB data import

# copy to container
docker cp $dump_file $container_id:/var

# create database
docker compose exec -it $db_container bash
psql -U postgres
create database dvdrental;

# user pg_restore
docker compose exec $db_container pg_restore -U $user -C -d postgres /var/$dump_file

Architecture

architecture

Logging Architecture

writing-datastores-kafka