sushi-bar / sushi-bar-be Goto Github PK

• Kafka listener tests (Docker)
• Kafka producer tests (Docker)

https://medium.com/@robgolder/kafka-schema-registry-avro-spring-boot-demo-1-of-2-ab9cba3ddbb2

Refer to your-rents-api

Bootstrap issue while executing SpringBootTest

2023-01-14 19:42:11.175 WARN 4987 --- [| adminclient-1] org.apache.kafka.clients.NetworkClient : [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:29092) could not be established. Broker may not be available. 2023-01-14 19:42:12.390 INFO 4987 --- [| adminclient-1] org.apache.kafka.clients.NetworkClient : [AdminClient clientId=adminclient-1] Node -1 disconnected.

Once the order is submitted figured out how to process the order:

• should be handled by a listener or pick it up from another rest api
• how to transform it and to submit as a meal or a task for the cook

• Architecture Outline
• Usage Guide: Comprehensive usage instructions and examples.
• Best Practices: Recommendations for effective utilisation.

• analyse how to limit cost
• which services of Azure are most suitable for this application

To define rest api to monitor status of submitted order.

• status of the order
• delete an existing order
• update status of an order

Being able to release a new version from cli

Basic functionalities for the cook app:

1. process the orders from the topic order
2. submit a new message in the topic meal

As a new user, I want to register by creating a username so that the system can remember me and my data.
Authentication should be based on an external identity provider, we could start with gmail.

source

web application tests should be integration tests using docker.

• spring security
• authentication based on gmail
• authorization

Links

1. https://github.com/Java-Techie-jt/spring-sso-google
2. https://www.youtube.com/watch?v=qcz2jBLNOtc&t=29s
3. google: google console

• GET status of a single order
• UPDATE status of a single order

00:59:40.739 [main] ERROR o.s.kafka.core.KafkaAdmin - Could not configure topics org.springframework.kafka.KafkaException: Timed out waiting to get existing topics at org.springframework.kafka.core.KafkaAdmin.lambda$checkPartitions$11(KafkaAdmin.java:520) at java.base/java.util.HashMap.forEach(HashMap.java:1429) at org.springframework.kafka.core.KafkaAdmin.checkPartitions(KafkaAdmin.java:499) at org.springframework.kafka.core.KafkaAdmin.addOrModifyTopicsIfNeeded(KafkaAdmin.java:392) at org.springframework.kafka.core.KafkaAdmin.initialize(KafkaAdmin.java:258) at org.springframework.kafka.core.KafkaAdmin.afterSingletonsInstantiated(KafkaAdmin.java:222) at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:986) at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:959) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:624) at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:146) at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:754) at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:456) at org.springframework.boot.SpringApplication.run(SpringApplication.java:334) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1354) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1343) at org.virtualsushibar.backend.app.MainApplication.main(MainApplication.java:12) Caused by: java.util.concurrent.TimeoutException: null at java.base/java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1960) at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2095) at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:180) at org.springframework.kafka.core.KafkaAdmin.lambda$checkPartitions$11(KafkaAdmin.java:502) ... 15 common frames omitted

• listen for the order in the orders topic
• simulate a delay representing the time spent for the meal preparation
• publishing the processed order in the corresponding processed-order topic

Use Kafka Streams instead of Generic Kafka Listeners and Producers

https://medium.com/@TimvanBaarsen/programmatically-create-kafka-topics-using-spring-kafka-8db5925ed2b1

Bump spring boot version to 3.1.0

As SushiBar registered user I want to submit my order and get a confirmationID.

https://www.testcontainers.org/

To have multiple brokers configured in Kafka

To use MongoDb to track orders, meals, deliveries.

https://dev.to/sonyarianto/how-to-spin-mongodb-server-with-docker-and-docker-compose-2lef