mindol1004/scs-100
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update README.md

Browse Source
This commit is contained in:
Jay Ehsaniara
2021-06-28 13:59:40 -07:00
parent 6a50fce657
commit 4a261bf67c
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
scs-100-2/material/kafka-events-intro-1002-1.svg
View File

File diff suppressed because one or more lines are too long
Side by Side Swipe Overlay

Before

Width:  |  Height:  |  Size: 36 KiB

After

Width:  |  Height:  |  Size: 126 KiB

4
scs-100-2/src/main/java/com/ehsaniara/scs_kafka_intro/scs1002/OrderService.java
View File

@@ -82,6 +82,7 @@ public class OrderService implements OrderTopology {
public Function<KStream<UUID, Order>, KStream<UUID, Order>[]> orderProcess() {
return input -> input
.peek((uuid, order) -> log.debug("Routing Order: {} [status: {}]", uuid, order.getOrderStatus()))
.map((uuid, order) -> {
try {
//create fake delay
@@ -98,14 +99,15 @@ public class OrderService implements OrderTopology {
@Bean
public Function<KStream<UUID, Order>, KStream<UUID, Order>> inventoryCheck() {
return input -> input
.peek((uuid, order) -> log.debug("Checking order inventory, Order: {}", uuid))
.peek((key, value) -> value.setOrderStatus(OrderStatus.INVENTORY_CHECKING))
.peek((uuid, order) -> log.debug("Order {} is getting checked in the inventory", uuid))
.map(KeyValue::new);
}
@Bean
public Function<KStream<UUID, Order>, KStream<UUID, Order>> shipping() {
return input -> input
.peek((uuid, order) -> log.debug("Applying Shipping Process, Order: {}", uuid))
.peek((key, value) -> value.setOrderStatus(OrderStatus.SHIPPED))
.map(KeyValue::new);
}