cqrs-kafka-golang

Overview

Start Kafka

zookeeper

C:\kafka_2.13-2.4.0\bin\windows/zookeeper-server-start.bat C:\kafka_2.13-2.4.0\config/zookeeper.properties

kafka

C:\kafka_2.13-2.4.0\bin\windows/kafka-server-start.bat C:\kafka_2.13-2.4.0\config/server.properties

Create Topic

From user.go:

-User

C:\kafka_2.13-2.4.0\bin\windows/kafka-topics.bat –create –zookeeper kafka-zookeeper:2181 –replication-factor 1 –partitions 1 –topic user-create

C:\kafka_2.13-2.4.0\bin\windows/kafka-topics.bat –create –zookeeper kafka-zookeeper:2181 –replication-factor 1 –partitions 1 –topic user-update

C:\kafka_2.13-2.4.0\bin\windows/kafka-topics.bat –create –zookeeper kafka-zookeeper:2181 –replication-factor 1 –partitions 1 –topic user-delete

-Product

C:\kafka_2.13-2.4.0\bin\windows/kafka-topics.bat –create –zookeeper kafka-zookeeper:2181 –replication-factor 1 –partitions 1 –topic product-create

C:\kafka_2.13-2.4.0\bin\windows/kafka-topics.bat –create –zookeeper kafka-zookeeper:2181 –replication-factor 1 –partitions 1 –topic product-update

C:\kafka_2.13-2.4.0\bin\windows/kafka-topics.bat –create –zookeeper kafka-zookeeper:2181 –replication-factor 1 –partitions 1 –topic product-delete

-order

C:\kafka_2.13-2.4.0\bin\windows/kafka-topics.bat –create –zookeeper kafka-zookeeper:2181 –replication-factor 1 –partitions 1 –topic order-create

C:\kafka_2.13-2.4.0\bin\windows/kafka-topics.bat –create –zookeeper kafka-zookeeper:2181 –replication-factor 1 –partitions 1 –topic order-update

C:\kafka_2.13-2.4.0\bin\windows/kafka-topics.bat –create –zookeeper kafka-zookeeper:2181 –replication-factor 1 –partitions 1 –topic order-delete

-orderdto

C:\kafka_2.13-2.4.0\bin\windows/kafka-topics.bat –create –zookeeper kafka-zookeeper:2181 –replication-factor 1 –partitions 1 –topic orderdto-create

C:\kafka_2.13-2.4.0\bin\windows/kafka-topics.bat –create –zookeeper kafka-zookeeper:2181 –replication-factor 1 –partitions 1 –topic orderdto-update

C:\kafka_2.13-2.4.0\bin\windows/kafka-topics.bat –create –zookeeper kafka-zookeeper:2181 –replication-factor 1 –partitions 1 –topic orderdto-delete

To see your messages

C:\kafka_2.13-2.4.0\bin\windows/kafka-console-consumer.bat -bootstrap-server kafka-zookeeper:9092 -topic user-create -from-beginning

Run Redis

docker run -d -p 6379:6379 --name redis redis

docker exec -it redis redis-cli

Run Postgresql

docker run -d -p 5432:5432 --name postgresql -e POSTGRES_PASSWORD=password postgres

docker exec -it postgresql /bin/sh

psql -h localhost -U postgres

docker exec -it postgresql psql -h localhost -U postgres

CREATE DATABASE cqrs;

\connect cqrs

CREATE TABLE cqrs_user( userid serial PRIMARY KEY, firstname VARCHAR (50) NOT NULL, lastname VARCHAR (50) NOT NULL, age integer NOT NULL, updatedate date NOT NULL, createdate date NOT NULL );

CREATE TABLE cqrs_product( productid serial PRIMARY KEY, name VARCHAR (50) NOT NULL, description VARCHAR (50) NOT NULL, updatedate date NOT NULL, createdate date NOT NULL );

CREATE TABLE cqrs_order( orderid serial PRIMARY KEY, userid integer NOT NULL, productid integer NOT NULL, quantity integer NOT NULL, orderDate date NOT NULL, shipDate date NOT NULL, updatedate date NOT NULL, createdate date NOT NULL );

insert into cqrs_user (userid, firstname, lastname, age, updatedate, createdate) values (default, 'myfirst', 'mylast', 36, NOW(), NOW()); insert into cqrs_user (userid, firstname, lastname, age, updatedate, createdate) values (default, 'myfirst2', 'mylast2', 37, NOW(), NOW());

insert into cqrs_product (productid, name, description, updatedate, createdate) values (default, 'goodproduct', 'very good product', NOW(), NOW()); insert into cqrs_product (productid, name, description, updatedate, createdate) values (default, 'goodproduct2', 'very good product2', NOW(), NOW());

insert into cqrs_order (orderid, userid, productid, quantity, orderdate, shipdate, updatedate, createdate) values (default, 1, 1, 243, NOW(), NOW(), NOW(), NOW()); insert into cqrs_order (orderid, userid, productid, quantity, orderdate, shipdate, updatedate, createdate) values (default, 2, 2, 243, NOW(), NOW(), NOW(), NOW()); insert into cqrs_order (orderid, userid, productid, quantity, orderdate, shipdate, updatedate, createdate) values (default, 1, 2, 243, NOW(), NOW(), NOW(), NOW());