Feature/remove saga (#768)

* Remove saga. For simplicity. Keep the saga implementation in saga branch
---------

Co-authored-by: khanhtranduy <130121475+khanhtranduy@users.noreply.github.com>

Author: khanhtrand

.env

@@ -67,7 +67,7 @@ LOGGING_CONFIG=/app-config/logback-spring.xml
 
 # The API Endpoint
 YAS_PUBLIC_API_URL=http://api.yas.local
-YAS_SERVICES_CART=http//cart/cart
+YAS_SERVICES_CART=http://cart/cart
 YAS_SERVICES_CUSTOMER=http://customer/customer
 YAS_SERVICES_PRODUCT=http://product/product
 YAS_SERVICES_TAX=http://tax/tax

cart/pom.xml

@@ -115,12 +115,6 @@
 			<groupId>org.liquibase</groupId>
 			<artifactId>liquibase-core</artifactId>
 		</dependency>
-		<dependency>
-			<groupId>com.yas</groupId>
-			<artifactId>saga</artifactId>
-			<version>0.0.1-SNAPSHOT</version>
-			<scope>compile</scope>
-		</dependency>
 	</dependencies>
 	<dependencyManagement>
 		<dependencies>

cart/src/main/java/com/yas/cart/saga/HandlerDispatcherRegister.java

@@ -8,11 +8,6 @@ management.endpoints.web.exposure.include=*
 management.metrics.distribution.percentiles-histogram.http.server.requests=true
 management.metrics.tags.application=${spring.application.name}
 
-eventuatelocal.kafka.bootstrap.servers=kafka:9092
-eventuatelocal.zookeeper.connection.string=zookeeper:2181
-eventuate.database.schema=eventuate
-spring.liquibase.parameters.eventualSlotName=cart
-
 logging.pattern.level=%5p [${spring.application.name:},%X{traceId:-},%X{spanId:-}]
 
 spring.security.oauth2.resourceserver.jwt.issuer-uri=http://identity/realms/Yas

cart/src/main/java/com/yas/cart/saga/handler/CartItemCommandHandler.java

@@ -3,5 +3,5 @@ databaseChangeLog:
       path: db/changelog/ddl/
   - includeAll:
       path: db/changelog/data/
-  - includeAll:
-      path: db/changelog/eventuate-dll/
+#  - includeAll:
+#      path: db/changelog/eventuate-dll/

cart/src/main/resources/application.properties

@@ -462,7 +462,7 @@ services:
     networks:
       - yas-network
   postgres:
-    image: debezium/postgres:15-alpine-custom
+    image: debezium/postgres:15-alpine
     build: ./docker/postgres
     hostname: ${POSTGRES_HOST}
     ports:
@@ -547,82 +547,6 @@ services:
     networks:
       - yas-network
 
-  eventuate-cdc:
-    image: eventuateio/eventuate-cdc-service:0.15.0.RELEASE
-    ports:
-      - "8099:8080"
-    depends_on:
-      - postgres
-      - kafka
-      - zookeeper
-    networks:
-      - yas-network
-    environment:
-      CDC_OPTS: "--debug"
-
-      EVENTUATELOCAL_KAFKA_BOOTSTRAP_SERVERS: kafka:29092
-      EVENTUATELOCAL_ZOOKEEPER_CONNECTION_STRING: zookeeper:2181
-
-      EVENTUATE_CDC_READER_READER1_TYPE: postgres-wal
-      EVENTUATE_CDC_READER_READER1_DATASOURCEURL: jdbc:postgresql://postgres/order
-      EVENTUATE_CDC_READER_READER1_MONITORINGSCHEMA: eventuate
-      EVENTUATE_CDC_READER_READER1_DATASOURCEUSERNAME: admin
-      EVENTUATE_CDC_READER_READER1_DATASOURCEPASSWORD: admin
-      EVENTUATE_CDC_READER_READER1_DATASOURCEDRIVERCLASSNAME: org.postgresql.Driver
-      EVENTUATE_CDC_READER_READER1_LEADERSHIPLOCKPATH: /eventuate/cdc/leader/order
-      EVENTUATE_CDC_READER_READER1_OFFSETSTORAGETOPICNAME: db.history.common
-      EVENTUATE_CDC_READER_READER1_OUTBOXID: 1
-      EVENTUATE_CDC_READER_READER1_POSTGRESREPLICATIONSLOTNAME: eventuate_slot_order
-
-      EVENTUATE_CDC_READER_READER2_TYPE: postgres-wal
-      EVENTUATE_CDC_READER_READER2_DATASOURCEURL: jdbc:postgresql://postgres/cart
-      EVENTUATE_CDC_READER_READER2_MONITORINGSCHEMA: eventuate
-      EVENTUATE_CDC_READER_READER2_DATASOURCEUSERNAME: admin
-      EVENTUATE_CDC_READER_READER2_DATASOURCEPASSWORD: admin
-      EVENTUATE_CDC_READER_READER2_DATASOURCEDRIVERCLASSNAME: org.postgresql.Driver
-      EVENTUATE_CDC_READER_READER2_LEADERSHIPLOCKPATH: /eventuate/cdc/leader/cart
-      EVENTUATE_CDC_READER_READER2_OFFSETSTORAGETOPICNAME: db.history.common
-      EVENTUATE_CDC_READER_READER2_OUTBOXID: 2
-      EVENTUATE_CDC_READER_READER2_POSTGRESREPLICATIONSLOTNAME: eventuate_slot_cart
-
-      EVENTUATE_CDC_READER_READER3_TYPE: postgres-wal
-      EVENTUATE_CDC_READER_READER3_DATASOURCEURL: jdbc:postgresql://postgres/payment
-      EVENTUATE_CDC_READER_READER3_MONITORINGSCHEMA: eventuate
-      EVENTUATE_CDC_READER_READER3_DATASOURCEUSERNAME: admin
-      EVENTUATE_CDC_READER_READER3_DATASOURCEPASSWORD: admin
-      EVENTUATE_CDC_READER_READER3_DATASOURCEDRIVERCLASSNAME: org.postgresql.Driver
-      EVENTUATE_CDC_READER_READER3_LEADERSHIPLOCKPATH: /eventuate/cdc/leader/payment
-      EVENTUATE_CDC_READER_READER3_OFFSETSTORAGETOPICNAME: db.history.common
-      EVENTUATE_CDC_READER_READER3_OUTBOXID: 3
-      EVENTUATE_CDC_READER_READER3_POSTGRESREPLICATIONSLOTNAME: eventuate_slot_payment
-
-      EVENTUATE_CDC_READER_READER4_TYPE: postgres-wal
-      EVENTUATE_CDC_READER_READER4_DATASOURCEURL: jdbc:postgresql://postgres/product
-      EVENTUATE_CDC_READER_READER4_MONITORINGSCHEMA: eventuate
-      EVENTUATE_CDC_READER_READER4_DATASOURCEUSERNAME: admin
-      EVENTUATE_CDC_READER_READER4_DATASOURCEPASSWORD: admin
-      EVENTUATE_CDC_READER_READER4_DATASOURCEDRIVERCLASSNAME: org.postgresql.Driver
-      EVENTUATE_CDC_READER_READER4_LEADERSHIPLOCKPATH: /eventuate/cdc/leader/product
-      EVENTUATE_CDC_READER_READER4_OFFSETSTORAGETOPICNAME: db.history.common
-      EVENTUATE_CDC_READER_READER4_OUTBOXID: 4
-      EVENTUATE_CDC_READER_READER4_POSTGRESREPLICATIONSLOTNAME: eventuate_slot_product
-
-      EVENTUATE_CDC_PIPELINE_PIPELINE1_TYPE: eventuate-tram
-      EVENTUATE_CDC_PIPELINE_PIPELINE1_READER: reader1
-      EVENTUATE_CDC_PIPELINE_PIPELINE1_EVENTUATEDATABASESCHEMA: eventuate
-
-      EVENTUATE_CDC_PIPELINE_PIPELINE2_TYPE: eventuate-tram
-      EVENTUATE_CDC_PIPELINE_PIPELINE2_READER: reader2
-      EVENTUATE_CDC_PIPELINE_PIPELINE2_EVENTUATEDATABASESCHEMA: eventuate
-
-      EVENTUATE_CDC_PIPELINE_PIPELINE3_TYPE: eventuate-tram
-      EVENTUATE_CDC_PIPELINE_PIPELINE3_READER: reader3
-      EVENTUATE_CDC_PIPELINE_PIPELINE3_EVENTUATEDATABASESCHEMA: eventuate
-
-      EVENTUATE_CDC_PIPELINE_PIPELINE4_TYPE: eventuate-tram
-      EVENTUATE_CDC_PIPELINE_PIPELINE4_READER: reader4
-      EVENTUATE_CDC_PIPELINE_PIPELINE4_EVENTUATEDATABASESCHEMA: eventuate
-
 networks:
   yas-network:
     driver: bridge

cart/src/main/resources/db/changelog/db.changelog-master.yaml

@@ -10,7 +10,6 @@ https://github.com/nashtech-garage/yas
 - [Change Data Capture (CDC) with Debezium](#change-data-capture-cdc-with-debezium)
 - [Product searching with Elasticsearch](#product-searching-with-elasticsearch)
 - [Duplicating data to improve performance](#duplicating-data-to-improve-performance)
-- [Saga pattern](#saga-pattern)
 - [Observability](#observability)
 - [Frontend architecture](#frontend-architecture)
 - [Local development with docker compose](#local-development-with-docker-compose)
@@ -195,8 +194,6 @@ Debezium acts as a source connector of Kafka connect. It captures row-level chan
 
 ## Duplicating data to improve performance
 
-## Saga pattern
-
 ## Observability
 
 ## Frontend architecture