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

Renaming orderStateStoreProcessor

Browse Source
This commit is contained in:
Jay Ehsaniara
2021-06-29 15:23:28 -07:00
parent 9a9617e81b
commit ff1c5c9177
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -30,7 +30,7 @@ public class OrderService implements OrderTopology {
private final Serde<Order> orderJsonSerde;
@Value("${spring.cloud.stream.bindings.orderAggConsumer-in-0.destination}")
@Value("${spring.cloud.stream.bindings.orderStateStoreProcessor-in-0.destination}")
private String orderTopic;
@Value("${spring.cloud.stream.kafka.streams.binder.brokers}")
@@ -66,7 +66,7 @@ public class OrderService implements OrderTopology {
}
@Bean
public Function<KStream<UUID, Order>, KStream<UUID, Order>> orderAggConsumer() {
public Function<KStream<UUID, Order>, KStream<UUID, Order>> orderStateStoreProcessor() {
return uuidOrderKStream -> {
KTable<UUID, String> uuidStringKTable = kStreamKTableStringFunction.apply(uuidOrderKStream);

8
scs-100-2/src/main/resources/application.yml
View File

@@ -1,11 +1,11 @@
spring:
application.name: scs-100-2
cloud.function.definition: orderAggConsumer;orderProcess;inventoryCheck;shipping;shippedConsumer
cloud.function.definition: orderStateStoreProcessor;orderProcess;inventoryCheck;shipping;shippedConsumer
spring.cloud.stream:
bindings:
orderAggConsumer-in-0.destination: scs-100-2.orderStatus
orderAggConsumer-out-0.destination: scs-100-2.orderProcess
orderStateStoreProcessor-in-0.destination: scs-100-2.orderStatus
orderStateStoreProcessor-out-0.destination: scs-100-2.orderProcess
orderProcess-in-0.destination: scs-100-2.orderProcess
orderProcess-out-0.destination: scs-100-2.inventoryCheck
@@ -22,7 +22,7 @@ spring.cloud.stream:
kafka.streams:
bindings:
orderAggConsumer-in-0.consumer.configuration.application.id: ${spring.application.name}-orderAggConsumer
orderStateStoreProcessor-in-0.consumer.configuration.application.id: ${spring.application.name}-orderStateStoreProcessor
orderProcess-in-0.consumer.configuration.application.id: ${spring.application.name}-orderProcess
inventoryCheck-in-0.consumer.configuration.application.id: ${spring.application.name}-inventoryCheck
shipping-in-0.consumer.configuration.application.id: ${spring.application.name}-shipping