rviana commited on
Commit
773626a
1 Parent(s): f5c26eb

Removing unrelated files.

Browse files
Files changed (30) hide show
  1. calculator-service +0 -1
  2. inventory-service/.gitignore +0 -37
  3. inventory-service/Dockerfile +0 -6
  4. inventory-service/build.gradle +0 -35
  5. inventory-service/gradle/wrapper/gradle-wrapper.jar +0 -0
  6. inventory-service/gradle/wrapper/gradle-wrapper.properties +0 -7
  7. inventory-service/gradlew +0 -249
  8. inventory-service/gradlew.bat +0 -92
  9. inventory-service/settings.gradle +0 -1
  10. inventory-service/src/main/java/com/inventory/dto/Order.java +0 -10
  11. inventory-service/src/main/java/com/inventory/inventoryservice/InventoryServiceApplication.java +0 -13
  12. inventory-service/src/main/java/com/inventory/model/Inventory.java +0 -21
  13. inventory-service/src/main/java/com/inventory/repository/InventoryRepository.java +0 -10
  14. inventory-service/src/main/java/com/inventory/service/InventoryService.java +0 -29
  15. inventory-service/src/main/resources/application.yml +0 -21
  16. inventory-service/src/test/java/com/inventory/inventoryservice/InventoryServiceApplicationTests.java +0 -13
  17. order-service/.gitignore +0 -37
  18. order-service/Dockerfile +0 -6
  19. order-service/build.gradle +0 -34
  20. order-service/gradle/wrapper/gradle-wrapper.jar +0 -0
  21. order-service/gradle/wrapper/gradle-wrapper.properties +0 -7
  22. order-service/gradlew +0 -249
  23. order-service/gradlew.bat +0 -92
  24. order-service/settings.gradle +0 -1
  25. order-service/src/main/java/com/order/controller/OrderController.java +0 -26
  26. order-service/src/main/java/com/order/dto/Order.java +0 -9
  27. order-service/src/main/java/com/order/orderservice/OrderServiceApplication.java +0 -13
  28. order-service/src/main/java/com/order/service/OrderService.java +0 -21
  29. order-service/src/main/resources/application.yml +0 -20
  30. order-service/src/test/java/com/order/orderservice/OrderServiceApplicationTests.java +0 -13
calculator-service DELETED
@@ -1 +0,0 @@
1
- Subproject commit 9dcdae443861d95097cc0a45bb8e68a23c2d5bc9
 
 
inventory-service/.gitignore DELETED
@@ -1,37 +0,0 @@
1
- HELP.md
2
- .gradle
3
- build/
4
- !gradle/wrapper/gradle-wrapper.jar
5
- !**/src/main/**/build/
6
- !**/src/test/**/build/
7
-
8
- ### STS ###
9
- .apt_generated
10
- .classpath
11
- .factorypath
12
- .project
13
- .settings
14
- .springBeans
15
- .sts4-cache
16
- bin/
17
- !**/src/main/**/bin/
18
- !**/src/test/**/bin/
19
-
20
- ### IntelliJ IDEA ###
21
- .idea
22
- *.iws
23
- *.iml
24
- *.ipr
25
- out/
26
- !**/src/main/**/out/
27
- !**/src/test/**/out/
28
-
29
- ### NetBeans ###
30
- /nbproject/private/
31
- /nbbuild/
32
- /dist/
33
- /nbdist/
34
- /.nb-gradle/
35
-
36
- ### VS Code ###
37
- .vscode/
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
inventory-service/Dockerfile DELETED
@@ -1,6 +0,0 @@
1
- # Dockerfile for Inventory-Service
2
- FROM openjdk:17-jdk-slim
3
- VOLUME /tmp
4
- ARG JAR_FILE=build/libs/inventory-service.jar
5
- COPY ${JAR_FILE} app.jar
6
- ENTRYPOINT ["java","-jar","/app.jar"]
 
 
 
 
 
 
 
inventory-service/build.gradle DELETED
@@ -1,35 +0,0 @@
1
- plugins {
2
- id 'java'
3
- id 'org.springframework.boot' version '3.3.1'
4
- id 'io.spring.dependency-management' version '1.1.5'
5
- }
6
-
7
- group = 'com.inventory'
8
- version = '0.0.1-SNAPSHOT'
9
-
10
- java {
11
- toolchain {
12
- languageVersion = JavaLanguageVersion.of(17)
13
- }
14
- }
15
-
16
- repositories {
17
- mavenCentral()
18
- }
19
-
20
- dependencies {
21
- implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
22
- implementation 'org.springframework.boot:spring-boot-starter-web'
23
- implementation 'org.springframework.kafka:spring-kafka'
24
- runtimeOnly 'com.h2database:h2'
25
- testImplementation 'org.springframework.boot:spring-boot-starter-test'
26
- testImplementation 'org.springframework.kafka:spring-kafka-test'
27
- testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
28
- compileOnly 'org.projectlombok:lombok:1.18.30'
29
- annotationProcessor 'org.projectlombok:lombok:1.18.30'
30
- implementation 'javax.persistence:javax.persistence-api:2.2'
31
- }
32
-
33
- tasks.named('test') {
34
- //useJUnitPlatform()
35
- }
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
inventory-service/gradle/wrapper/gradle-wrapper.jar DELETED
Binary file (43.5 kB)
 
inventory-service/gradle/wrapper/gradle-wrapper.properties DELETED
@@ -1,7 +0,0 @@
1
- distributionBase=GRADLE_USER_HOME
2
- distributionPath=wrapper/dists
3
- distributionUrl=https\://services.gradle.org/distributions/gradle-8.8-bin.zip
4
- networkTimeout=10000
5
- validateDistributionUrl=true
6
- zipStoreBase=GRADLE_USER_HOME
7
- zipStorePath=wrapper/dists
 
 
 
 
 
 
 
 
inventory-service/gradlew DELETED
@@ -1,249 +0,0 @@
1
- #!/bin/sh
2
-
3
- #
4
- # Copyright © 2015-2021 the original authors.
5
- #
6
- # Licensed under the Apache License, Version 2.0 (the "License");
7
- # you may not use this file except in compliance with the License.
8
- # You may obtain a copy of the License at
9
- #
10
- # https://www.apache.org/licenses/LICENSE-2.0
11
- #
12
- # Unless required by applicable law or agreed to in writing, software
13
- # distributed under the License is distributed on an "AS IS" BASIS,
14
- # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15
- # See the License for the specific language governing permissions and
16
- # limitations under the License.
17
- #
18
-
19
- ##############################################################################
20
- #
21
- # Gradle start up script for POSIX generated by Gradle.
22
- #
23
- # Important for running:
24
- #
25
- # (1) You need a POSIX-compliant shell to run this script. If your /bin/sh is
26
- # noncompliant, but you have some other compliant shell such as ksh or
27
- # bash, then to run this script, type that shell name before the whole
28
- # command line, like:
29
- #
30
- # ksh Gradle
31
- #
32
- # Busybox and similar reduced shells will NOT work, because this script
33
- # requires all of these POSIX shell features:
34
- # * functions;
35
- # * expansions «$var», «${var}», «${var:-default}», «${var+SET}»,
36
- # «${var#prefix}», «${var%suffix}», and «$( cmd )»;
37
- # * compound commands having a testable exit status, especially «case»;
38
- # * various built-in commands including «command», «set», and «ulimit».
39
- #
40
- # Important for patching:
41
- #
42
- # (2) This script targets any POSIX shell, so it avoids extensions provided
43
- # by Bash, Ksh, etc; in particular arrays are avoided.
44
- #
45
- # The "traditional" practice of packing multiple parameters into a
46
- # space-separated string is a well documented source of bugs and security
47
- # problems, so this is (mostly) avoided, by progressively accumulating
48
- # options in "$@", and eventually passing that to Java.
49
- #
50
- # Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS,
51
- # and GRADLE_OPTS) rely on word-splitting, this is performed explicitly;
52
- # see the in-line comments for details.
53
- #
54
- # There are tweaks for specific operating systems such as AIX, CygWin,
55
- # Darwin, MinGW, and NonStop.
56
- #
57
- # (3) This script is generated from the Groovy template
58
- # https://github.com/gradle/gradle/blob/HEAD/platforms/jvm/plugins-application/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
59
- # within the Gradle project.
60
- #
61
- # You can find Gradle at https://github.com/gradle/gradle/.
62
- #
63
- ##############################################################################
64
-
65
- # Attempt to set APP_HOME
66
-
67
- # Resolve links: $0 may be a link
68
- app_path=$0
69
-
70
- # Need this for daisy-chained symlinks.
71
- while
72
- APP_HOME=${app_path%"${app_path##*/}"} # leaves a trailing /; empty if no leading path
73
- [ -h "$app_path" ]
74
- do
75
- ls=$( ls -ld "$app_path" )
76
- link=${ls#*' -> '}
77
- case $link in #(
78
- /*) app_path=$link ;; #(
79
- *) app_path=$APP_HOME$link ;;
80
- esac
81
- done
82
-
83
- # This is normally unused
84
- # shellcheck disable=SC2034
85
- APP_BASE_NAME=${0##*/}
86
- # Discard cd standard output in case $CDPATH is set (https://github.com/gradle/gradle/issues/25036)
87
- APP_HOME=$( cd "${APP_HOME:-./}" > /dev/null && pwd -P ) || exit
88
-
89
- # Use the maximum available, or set MAX_FD != -1 to use that value.
90
- MAX_FD=maximum
91
-
92
- warn () {
93
- echo "$*"
94
- } >&2
95
-
96
- die () {
97
- echo
98
- echo "$*"
99
- echo
100
- exit 1
101
- } >&2
102
-
103
- # OS specific support (must be 'true' or 'false').
104
- cygwin=false
105
- msys=false
106
- darwin=false
107
- nonstop=false
108
- case "$( uname )" in #(
109
- CYGWIN* ) cygwin=true ;; #(
110
- Darwin* ) darwin=true ;; #(
111
- MSYS* | MINGW* ) msys=true ;; #(
112
- NONSTOP* ) nonstop=true ;;
113
- esac
114
-
115
- CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
116
-
117
-
118
- # Determine the Java command to use to start the JVM.
119
- if [ -n "$JAVA_HOME" ] ; then
120
- if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
121
- # IBM's JDK on AIX uses strange locations for the executables
122
- JAVACMD=$JAVA_HOME/jre/sh/java
123
- else
124
- JAVACMD=$JAVA_HOME/bin/java
125
- fi
126
- if [ ! -x "$JAVACMD" ] ; then
127
- die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
128
-
129
- Please set the JAVA_HOME variable in your environment to match the
130
- location of your Java installation."
131
- fi
132
- else
133
- JAVACMD=java
134
- if ! command -v java >/dev/null 2>&1
135
- then
136
- die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
137
-
138
- Please set the JAVA_HOME variable in your environment to match the
139
- location of your Java installation."
140
- fi
141
- fi
142
-
143
- # Increase the maximum file descriptors if we can.
144
- if ! "$cygwin" && ! "$darwin" && ! "$nonstop" ; then
145
- case $MAX_FD in #(
146
- max*)
147
- # In POSIX sh, ulimit -H is undefined. That's why the result is checked to see if it worked.
148
- # shellcheck disable=SC2039,SC3045
149
- MAX_FD=$( ulimit -H -n ) ||
150
- warn "Could not query maximum file descriptor limit"
151
- esac
152
- case $MAX_FD in #(
153
- '' | soft) :;; #(
154
- *)
155
- # In POSIX sh, ulimit -n is undefined. That's why the result is checked to see if it worked.
156
- # shellcheck disable=SC2039,SC3045
157
- ulimit -n "$MAX_FD" ||
158
- warn "Could not set maximum file descriptor limit to $MAX_FD"
159
- esac
160
- fi
161
-
162
- # Collect all arguments for the java command, stacking in reverse order:
163
- # * args from the command line
164
- # * the main class name
165
- # * -classpath
166
- # * -D...appname settings
167
- # * --module-path (only if needed)
168
- # * DEFAULT_JVM_OPTS, JAVA_OPTS, and GRADLE_OPTS environment variables.
169
-
170
- # For Cygwin or MSYS, switch paths to Windows format before running java
171
- if "$cygwin" || "$msys" ; then
172
- APP_HOME=$( cygpath --path --mixed "$APP_HOME" )
173
- CLASSPATH=$( cygpath --path --mixed "$CLASSPATH" )
174
-
175
- JAVACMD=$( cygpath --unix "$JAVACMD" )
176
-
177
- # Now convert the arguments - kludge to limit ourselves to /bin/sh
178
- for arg do
179
- if
180
- case $arg in #(
181
- -*) false ;; # don't mess with options #(
182
- /?*) t=${arg#/} t=/${t%%/*} # looks like a POSIX filepath
183
- [ -e "$t" ] ;; #(
184
- *) false ;;
185
- esac
186
- then
187
- arg=$( cygpath --path --ignore --mixed "$arg" )
188
- fi
189
- # Roll the args list around exactly as many times as the number of
190
- # args, so each arg winds up back in the position where it started, but
191
- # possibly modified.
192
- #
193
- # NB: a `for` loop captures its iteration list before it begins, so
194
- # changing the positional parameters here affects neither the number of
195
- # iterations, nor the values presented in `arg`.
196
- shift # remove old arg
197
- set -- "$@" "$arg" # push replacement arg
198
- done
199
- fi
200
-
201
-
202
- # Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
203
- DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
204
-
205
- # Collect all arguments for the java command:
206
- # * DEFAULT_JVM_OPTS, JAVA_OPTS, JAVA_OPTS, and optsEnvironmentVar are not allowed to contain shell fragments,
207
- # and any embedded shellness will be escaped.
208
- # * For example: A user cannot expect ${Hostname} to be expanded, as it is an environment variable and will be
209
- # treated as '${Hostname}' itself on the command line.
210
-
211
- set -- \
212
- "-Dorg.gradle.appname=$APP_BASE_NAME" \
213
- -classpath "$CLASSPATH" \
214
- org.gradle.wrapper.GradleWrapperMain \
215
- "$@"
216
-
217
- # Stop when "xargs" is not available.
218
- if ! command -v xargs >/dev/null 2>&1
219
- then
220
- die "xargs is not available"
221
- fi
222
-
223
- # Use "xargs" to parse quoted args.
224
- #
225
- # With -n1 it outputs one arg per line, with the quotes and backslashes removed.
226
- #
227
- # In Bash we could simply go:
228
- #
229
- # readarray ARGS < <( xargs -n1 <<<"$var" ) &&
230
- # set -- "${ARGS[@]}" "$@"
231
- #
232
- # but POSIX shell has neither arrays nor command substitution, so instead we
233
- # post-process each arg (as a line of input to sed) to backslash-escape any
234
- # character that might be a shell metacharacter, then use eval to reverse
235
- # that process (while maintaining the separation between arguments), and wrap
236
- # the whole thing up as a single "set" statement.
237
- #
238
- # This will of course break if any of these variables contains a newline or
239
- # an unmatched quote.
240
- #
241
-
242
- eval "set -- $(
243
- printf '%s\n' "$DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS" |
244
- xargs -n1 |
245
- sed ' s~[^-[:alnum:]+,./:=@_]~\\&~g; ' |
246
- tr '\n' ' '
247
- )" '"$@"'
248
-
249
- exec "$JAVACMD" "$@"
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
inventory-service/gradlew.bat DELETED
@@ -1,92 +0,0 @@
1
- @rem
2
- @rem Copyright 2015 the original author or authors.
3
- @rem
4
- @rem Licensed under the Apache License, Version 2.0 (the "License");
5
- @rem you may not use this file except in compliance with the License.
6
- @rem You may obtain a copy of the License at
7
- @rem
8
- @rem https://www.apache.org/licenses/LICENSE-2.0
9
- @rem
10
- @rem Unless required by applicable law or agreed to in writing, software
11
- @rem distributed under the License is distributed on an "AS IS" BASIS,
12
- @rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
- @rem See the License for the specific language governing permissions and
14
- @rem limitations under the License.
15
- @rem
16
-
17
- @if "%DEBUG%"=="" @echo off
18
- @rem ##########################################################################
19
- @rem
20
- @rem Gradle startup script for Windows
21
- @rem
22
- @rem ##########################################################################
23
-
24
- @rem Set local scope for the variables with windows NT shell
25
- if "%OS%"=="Windows_NT" setlocal
26
-
27
- set DIRNAME=%~dp0
28
- if "%DIRNAME%"=="" set DIRNAME=.
29
- @rem This is normally unused
30
- set APP_BASE_NAME=%~n0
31
- set APP_HOME=%DIRNAME%
32
-
33
- @rem Resolve any "." and ".." in APP_HOME to make it shorter.
34
- for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
35
-
36
- @rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
37
- set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m"
38
-
39
- @rem Find java.exe
40
- if defined JAVA_HOME goto findJavaFromJavaHome
41
-
42
- set JAVA_EXE=java.exe
43
- %JAVA_EXE% -version >NUL 2>&1
44
- if %ERRORLEVEL% equ 0 goto execute
45
-
46
- echo. 1>&2
47
- echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. 1>&2
48
- echo. 1>&2
49
- echo Please set the JAVA_HOME variable in your environment to match the 1>&2
50
- echo location of your Java installation. 1>&2
51
-
52
- goto fail
53
-
54
- :findJavaFromJavaHome
55
- set JAVA_HOME=%JAVA_HOME:"=%
56
- set JAVA_EXE=%JAVA_HOME%/bin/java.exe
57
-
58
- if exist "%JAVA_EXE%" goto execute
59
-
60
- echo. 1>&2
61
- echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME% 1>&2
62
- echo. 1>&2
63
- echo Please set the JAVA_HOME variable in your environment to match the 1>&2
64
- echo location of your Java installation. 1>&2
65
-
66
- goto fail
67
-
68
- :execute
69
- @rem Setup the command line
70
-
71
- set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
72
-
73
-
74
- @rem Execute Gradle
75
- "%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %*
76
-
77
- :end
78
- @rem End local scope for the variables with windows NT shell
79
- if %ERRORLEVEL% equ 0 goto mainEnd
80
-
81
- :fail
82
- rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
83
- rem the _cmd.exe /c_ return code!
84
- set EXIT_CODE=%ERRORLEVEL%
85
- if %EXIT_CODE% equ 0 set EXIT_CODE=1
86
- if not ""=="%GRADLE_EXIT_CONSOLE%" exit %EXIT_CODE%
87
- exit /b %EXIT_CODE%
88
-
89
- :mainEnd
90
- if "%OS%"=="Windows_NT" endlocal
91
-
92
- :omega
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
inventory-service/settings.gradle DELETED
@@ -1 +0,0 @@
1
- rootProject.name = 'inventory-service'
 
 
inventory-service/src/main/java/com/inventory/dto/Order.java DELETED
@@ -1,10 +0,0 @@
1
- package com.inventory.dto;
2
-
3
- import lombok.Data;
4
-
5
- @Data
6
- public class Order {
7
-
8
- private String productId;
9
- private int quantity;
10
- }
 
 
 
 
 
 
 
 
 
 
 
inventory-service/src/main/java/com/inventory/inventoryservice/InventoryServiceApplication.java DELETED
@@ -1,13 +0,0 @@
1
- package com.inventory.inventoryservice;
2
-
3
- import org.springframework.boot.SpringApplication;
4
- import org.springframework.boot.autoconfigure.SpringBootApplication;
5
-
6
- @SpringBootApplication
7
- public class InventoryServiceApplication {
8
-
9
- public static void main(String[] args) {
10
- SpringApplication.run(InventoryServiceApplication.class, args);
11
- }
12
-
13
- }
 
 
 
 
 
 
 
 
 
 
 
 
 
 
inventory-service/src/main/java/com/inventory/model/Inventory.java DELETED
@@ -1,21 +0,0 @@
1
- package com.inventory.model;
2
-
3
- import lombok.Data;
4
-
5
- import javax.persistence.Entity;
6
- import javax.persistence.GeneratedValue;
7
- import javax.persistence.GenerationType;
8
- import javax.persistence.Id;
9
-
10
- @Entity
11
- @Data
12
- public class Inventory {
13
-
14
- @Id
15
- @GeneratedValue(strategy = GenerationType.IDENTITY)
16
- private Long id;
17
- private String productId;
18
- private int quantity;
19
-
20
- // Getters and setters
21
- }
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
inventory-service/src/main/java/com/inventory/repository/InventoryRepository.java DELETED
@@ -1,10 +0,0 @@
1
- package com.inventory.repository;
2
-
3
- import com.inventory.model.Inventory;
4
- import org.springframework.data.jpa.repository.JpaRepository;
5
- import org.springframework.stereotype.Repository;
6
-
7
- @Repository
8
- public interface InventoryRepository extends JpaRepository<Inventory, Long> {
9
- Inventory findByProductId(String productId);
10
- }
 
 
 
 
 
 
 
 
 
 
 
inventory-service/src/main/java/com/inventory/service/InventoryService.java DELETED
@@ -1,29 +0,0 @@
1
- package com.inventory.service;
2
-
3
- import com.inventory.model.Inventory;
4
- import com.inventory.dto.Order;
5
- import com.inventory.repository.InventoryRepository;
6
- import org.springframework.beans.factory.annotation.Autowired;
7
- import org.springframework.kafka.annotation.KafkaListener;
8
- import org.springframework.stereotype.Service;
9
- import org.springframework.transaction.annotation.Transactional;
10
-
11
- @Service
12
- public class InventoryService {
13
-
14
- @Autowired
15
- private InventoryRepository inventoryRepository;
16
-
17
- @Transactional
18
- @KafkaListener(topics = "order-topic", groupId = "inventory-group")
19
- public void listen(Order order) {
20
- Inventory inventory = inventoryRepository.findByProductId(order.getProductId());
21
- if (inventory != null && inventory.getQuantity() >= order.getQuantity()) {
22
- inventory.setQuantity(inventory.getQuantity() - order.getQuantity());
23
- inventoryRepository.save(inventory);
24
- } else {
25
- // Handle insufficient inventory
26
- System.out.println("Insufficient inventory for product ID: " + order.getProductId());
27
- }
28
- }
29
- }
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
inventory-service/src/main/resources/application.yml DELETED
@@ -1,21 +0,0 @@
1
- server:
2
- port: 8082
3
-
4
- spring:
5
- datasource:
6
- url: jdbc:h2:mem:testdb
7
- driverClassName: org.h2.Driver
8
- username: sa
9
- password: password
10
- jpa:
11
- database-platform: org.hibernate.dialect.H2Dialect
12
- hibernate:
13
- ddl-auto: update
14
-
15
- kafka:
16
- bootstrap-servers: kafka:9092
17
- consumer:
18
- group-id: inventory-group
19
- auto-offset-reset: earliest
20
- key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
21
- value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
inventory-service/src/test/java/com/inventory/inventoryservice/InventoryServiceApplicationTests.java DELETED
@@ -1,13 +0,0 @@
1
- package com.inventory.inventoryservice;
2
-
3
- import org.junit.jupiter.api.Test;
4
- import org.springframework.boot.test.context.SpringBootTest;
5
-
6
- @SpringBootTest
7
- class InventoryServiceApplicationTests {
8
-
9
- @Test
10
- void contextLoads() {
11
- }
12
-
13
- }
 
 
 
 
 
 
 
 
 
 
 
 
 
 
order-service/.gitignore DELETED
@@ -1,37 +0,0 @@
1
- HELP.md
2
- .gradle
3
- build/
4
- !gradle/wrapper/gradle-wrapper.jar
5
- !**/src/main/**/build/
6
- !**/src/test/**/build/
7
-
8
- ### STS ###
9
- .apt_generated
10
- .classpath
11
- .factorypath
12
- .project
13
- .settings
14
- .springBeans
15
- .sts4-cache
16
- bin/
17
- !**/src/main/**/bin/
18
- !**/src/test/**/bin/
19
-
20
- ### IntelliJ IDEA ###
21
- .idea
22
- *.iws
23
- *.iml
24
- *.ipr
25
- out/
26
- !**/src/main/**/out/
27
- !**/src/test/**/out/
28
-
29
- ### NetBeans ###
30
- /nbproject/private/
31
- /nbbuild/
32
- /dist/
33
- /nbdist/
34
- /.nb-gradle/
35
-
36
- ### VS Code ###
37
- .vscode/
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
order-service/Dockerfile DELETED
@@ -1,6 +0,0 @@
1
- # Dockerfile for Order-Service
2
- FROM openjdk:17-jdk-slim
3
- VOLUME /tmp
4
- ARG JAR_FILE=build/libs/order-service.jar
5
- COPY ${JAR_FILE} app.jar
6
- ENTRYPOINT ["java","-jar","/app.jar"]
 
 
 
 
 
 
 
order-service/build.gradle DELETED
@@ -1,34 +0,0 @@
1
- plugins {
2
- id 'java'
3
- id 'org.springframework.boot' version '3.3.1'
4
- id 'io.spring.dependency-management' version '1.1.5'
5
- }
6
-
7
- group = 'com.order'
8
- version = '0.0.1-SNAPSHOT'
9
-
10
- java {
11
- toolchain {
12
- languageVersion = JavaLanguageVersion.of(17)
13
- }
14
- }
15
-
16
- repositories {
17
- mavenCentral()
18
- }
19
-
20
- dependencies {
21
- compileOnly 'org.projectlombok:lombok:1.18.30'
22
- annotationProcessor 'org.projectlombok:lombok:1.18.30'
23
- implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
24
- implementation 'org.springframework.boot:spring-boot-starter-web'
25
- implementation 'org.springframework.kafka:spring-kafka'
26
- runtimeOnly 'com.h2database:h2'
27
- testImplementation 'org.springframework.boot:spring-boot-starter-test'
28
- testImplementation 'org.springframework.kafka:spring-kafka-test'
29
- testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
30
- }
31
-
32
- tasks.named('test') {
33
- useJUnitPlatform()
34
- }
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
order-service/gradle/wrapper/gradle-wrapper.jar DELETED
Binary file (43.5 kB)
 
order-service/gradle/wrapper/gradle-wrapper.properties DELETED
@@ -1,7 +0,0 @@
1
- distributionBase=GRADLE_USER_HOME
2
- distributionPath=wrapper/dists
3
- distributionUrl=https\://services.gradle.org/distributions/gradle-8.8-bin.zip
4
- networkTimeout=10000
5
- validateDistributionUrl=true
6
- zipStoreBase=GRADLE_USER_HOME
7
- zipStorePath=wrapper/dists
 
 
 
 
 
 
 
 
order-service/gradlew DELETED
@@ -1,249 +0,0 @@
1
- #!/bin/sh
2
-
3
- #
4
- # Copyright © 2015-2021 the original authors.
5
- #
6
- # Licensed under the Apache License, Version 2.0 (the "License");
7
- # you may not use this file except in compliance with the License.
8
- # You may obtain a copy of the License at
9
- #
10
- # https://www.apache.org/licenses/LICENSE-2.0
11
- #
12
- # Unless required by applicable law or agreed to in writing, software
13
- # distributed under the License is distributed on an "AS IS" BASIS,
14
- # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15
- # See the License for the specific language governing permissions and
16
- # limitations under the License.
17
- #
18
-
19
- ##############################################################################
20
- #
21
- # Gradle start up script for POSIX generated by Gradle.
22
- #
23
- # Important for running:
24
- #
25
- # (1) You need a POSIX-compliant shell to run this script. If your /bin/sh is
26
- # noncompliant, but you have some other compliant shell such as ksh or
27
- # bash, then to run this script, type that shell name before the whole
28
- # command line, like:
29
- #
30
- # ksh Gradle
31
- #
32
- # Busybox and similar reduced shells will NOT work, because this script
33
- # requires all of these POSIX shell features:
34
- # * functions;
35
- # * expansions «$var», «${var}», «${var:-default}», «${var+SET}»,
36
- # «${var#prefix}», «${var%suffix}», and «$( cmd )»;
37
- # * compound commands having a testable exit status, especially «case»;
38
- # * various built-in commands including «command», «set», and «ulimit».
39
- #
40
- # Important for patching:
41
- #
42
- # (2) This script targets any POSIX shell, so it avoids extensions provided
43
- # by Bash, Ksh, etc; in particular arrays are avoided.
44
- #
45
- # The "traditional" practice of packing multiple parameters into a
46
- # space-separated string is a well documented source of bugs and security
47
- # problems, so this is (mostly) avoided, by progressively accumulating
48
- # options in "$@", and eventually passing that to Java.
49
- #
50
- # Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS,
51
- # and GRADLE_OPTS) rely on word-splitting, this is performed explicitly;
52
- # see the in-line comments for details.
53
- #
54
- # There are tweaks for specific operating systems such as AIX, CygWin,
55
- # Darwin, MinGW, and NonStop.
56
- #
57
- # (3) This script is generated from the Groovy template
58
- # https://github.com/gradle/gradle/blob/HEAD/platforms/jvm/plugins-application/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
59
- # within the Gradle project.
60
- #
61
- # You can find Gradle at https://github.com/gradle/gradle/.
62
- #
63
- ##############################################################################
64
-
65
- # Attempt to set APP_HOME
66
-
67
- # Resolve links: $0 may be a link
68
- app_path=$0
69
-
70
- # Need this for daisy-chained symlinks.
71
- while
72
- APP_HOME=${app_path%"${app_path##*/}"} # leaves a trailing /; empty if no leading path
73
- [ -h "$app_path" ]
74
- do
75
- ls=$( ls -ld "$app_path" )
76
- link=${ls#*' -> '}
77
- case $link in #(
78
- /*) app_path=$link ;; #(
79
- *) app_path=$APP_HOME$link ;;
80
- esac
81
- done
82
-
83
- # This is normally unused
84
- # shellcheck disable=SC2034
85
- APP_BASE_NAME=${0##*/}
86
- # Discard cd standard output in case $CDPATH is set (https://github.com/gradle/gradle/issues/25036)
87
- APP_HOME=$( cd "${APP_HOME:-./}" > /dev/null && pwd -P ) || exit
88
-
89
- # Use the maximum available, or set MAX_FD != -1 to use that value.
90
- MAX_FD=maximum
91
-
92
- warn () {
93
- echo "$*"
94
- } >&2
95
-
96
- die () {
97
- echo
98
- echo "$*"
99
- echo
100
- exit 1
101
- } >&2
102
-
103
- # OS specific support (must be 'true' or 'false').
104
- cygwin=false
105
- msys=false
106
- darwin=false
107
- nonstop=false
108
- case "$( uname )" in #(
109
- CYGWIN* ) cygwin=true ;; #(
110
- Darwin* ) darwin=true ;; #(
111
- MSYS* | MINGW* ) msys=true ;; #(
112
- NONSTOP* ) nonstop=true ;;
113
- esac
114
-
115
- CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
116
-
117
-
118
- # Determine the Java command to use to start the JVM.
119
- if [ -n "$JAVA_HOME" ] ; then
120
- if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
121
- # IBM's JDK on AIX uses strange locations for the executables
122
- JAVACMD=$JAVA_HOME/jre/sh/java
123
- else
124
- JAVACMD=$JAVA_HOME/bin/java
125
- fi
126
- if [ ! -x "$JAVACMD" ] ; then
127
- die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
128
-
129
- Please set the JAVA_HOME variable in your environment to match the
130
- location of your Java installation."
131
- fi
132
- else
133
- JAVACMD=java
134
- if ! command -v java >/dev/null 2>&1
135
- then
136
- die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
137
-
138
- Please set the JAVA_HOME variable in your environment to match the
139
- location of your Java installation."
140
- fi
141
- fi
142
-
143
- # Increase the maximum file descriptors if we can.
144
- if ! "$cygwin" && ! "$darwin" && ! "$nonstop" ; then
145
- case $MAX_FD in #(
146
- max*)
147
- # In POSIX sh, ulimit -H is undefined. That's why the result is checked to see if it worked.
148
- # shellcheck disable=SC2039,SC3045
149
- MAX_FD=$( ulimit -H -n ) ||
150
- warn "Could not query maximum file descriptor limit"
151
- esac
152
- case $MAX_FD in #(
153
- '' | soft) :;; #(
154
- *)
155
- # In POSIX sh, ulimit -n is undefined. That's why the result is checked to see if it worked.
156
- # shellcheck disable=SC2039,SC3045
157
- ulimit -n "$MAX_FD" ||
158
- warn "Could not set maximum file descriptor limit to $MAX_FD"
159
- esac
160
- fi
161
-
162
- # Collect all arguments for the java command, stacking in reverse order:
163
- # * args from the command line
164
- # * the main class name
165
- # * -classpath
166
- # * -D...appname settings
167
- # * --module-path (only if needed)
168
- # * DEFAULT_JVM_OPTS, JAVA_OPTS, and GRADLE_OPTS environment variables.
169
-
170
- # For Cygwin or MSYS, switch paths to Windows format before running java
171
- if "$cygwin" || "$msys" ; then
172
- APP_HOME=$( cygpath --path --mixed "$APP_HOME" )
173
- CLASSPATH=$( cygpath --path --mixed "$CLASSPATH" )
174
-
175
- JAVACMD=$( cygpath --unix "$JAVACMD" )
176
-
177
- # Now convert the arguments - kludge to limit ourselves to /bin/sh
178
- for arg do
179
- if
180
- case $arg in #(
181
- -*) false ;; # don't mess with options #(
182
- /?*) t=${arg#/} t=/${t%%/*} # looks like a POSIX filepath
183
- [ -e "$t" ] ;; #(
184
- *) false ;;
185
- esac
186
- then
187
- arg=$( cygpath --path --ignore --mixed "$arg" )
188
- fi
189
- # Roll the args list around exactly as many times as the number of
190
- # args, so each arg winds up back in the position where it started, but
191
- # possibly modified.
192
- #
193
- # NB: a `for` loop captures its iteration list before it begins, so
194
- # changing the positional parameters here affects neither the number of
195
- # iterations, nor the values presented in `arg`.
196
- shift # remove old arg
197
- set -- "$@" "$arg" # push replacement arg
198
- done
199
- fi
200
-
201
-
202
- # Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
203
- DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
204
-
205
- # Collect all arguments for the java command:
206
- # * DEFAULT_JVM_OPTS, JAVA_OPTS, JAVA_OPTS, and optsEnvironmentVar are not allowed to contain shell fragments,
207
- # and any embedded shellness will be escaped.
208
- # * For example: A user cannot expect ${Hostname} to be expanded, as it is an environment variable and will be
209
- # treated as '${Hostname}' itself on the command line.
210
-
211
- set -- \
212
- "-Dorg.gradle.appname=$APP_BASE_NAME" \
213
- -classpath "$CLASSPATH" \
214
- org.gradle.wrapper.GradleWrapperMain \
215
- "$@"
216
-
217
- # Stop when "xargs" is not available.
218
- if ! command -v xargs >/dev/null 2>&1
219
- then
220
- die "xargs is not available"
221
- fi
222
-
223
- # Use "xargs" to parse quoted args.
224
- #
225
- # With -n1 it outputs one arg per line, with the quotes and backslashes removed.
226
- #
227
- # In Bash we could simply go:
228
- #
229
- # readarray ARGS < <( xargs -n1 <<<"$var" ) &&
230
- # set -- "${ARGS[@]}" "$@"
231
- #
232
- # but POSIX shell has neither arrays nor command substitution, so instead we
233
- # post-process each arg (as a line of input to sed) to backslash-escape any
234
- # character that might be a shell metacharacter, then use eval to reverse
235
- # that process (while maintaining the separation between arguments), and wrap
236
- # the whole thing up as a single "set" statement.
237
- #
238
- # This will of course break if any of these variables contains a newline or
239
- # an unmatched quote.
240
- #
241
-
242
- eval "set -- $(
243
- printf '%s\n' "$DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS" |
244
- xargs -n1 |
245
- sed ' s~[^-[:alnum:]+,./:=@_]~\\&~g; ' |
246
- tr '\n' ' '
247
- )" '"$@"'
248
-
249
- exec "$JAVACMD" "$@"
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
order-service/gradlew.bat DELETED
@@ -1,92 +0,0 @@
1
- @rem
2
- @rem Copyright 2015 the original author or authors.
3
- @rem
4
- @rem Licensed under the Apache License, Version 2.0 (the "License");
5
- @rem you may not use this file except in compliance with the License.
6
- @rem You may obtain a copy of the License at
7
- @rem
8
- @rem https://www.apache.org/licenses/LICENSE-2.0
9
- @rem
10
- @rem Unless required by applicable law or agreed to in writing, software
11
- @rem distributed under the License is distributed on an "AS IS" BASIS,
12
- @rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
- @rem See the License for the specific language governing permissions and
14
- @rem limitations under the License.
15
- @rem
16
-
17
- @if "%DEBUG%"=="" @echo off
18
- @rem ##########################################################################
19
- @rem
20
- @rem Gradle startup script for Windows
21
- @rem
22
- @rem ##########################################################################
23
-
24
- @rem Set local scope for the variables with windows NT shell
25
- if "%OS%"=="Windows_NT" setlocal
26
-
27
- set DIRNAME=%~dp0
28
- if "%DIRNAME%"=="" set DIRNAME=.
29
- @rem This is normally unused
30
- set APP_BASE_NAME=%~n0
31
- set APP_HOME=%DIRNAME%
32
-
33
- @rem Resolve any "." and ".." in APP_HOME to make it shorter.
34
- for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
35
-
36
- @rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
37
- set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m"
38
-
39
- @rem Find java.exe
40
- if defined JAVA_HOME goto findJavaFromJavaHome
41
-
42
- set JAVA_EXE=java.exe
43
- %JAVA_EXE% -version >NUL 2>&1
44
- if %ERRORLEVEL% equ 0 goto execute
45
-
46
- echo. 1>&2
47
- echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. 1>&2
48
- echo. 1>&2
49
- echo Please set the JAVA_HOME variable in your environment to match the 1>&2
50
- echo location of your Java installation. 1>&2
51
-
52
- goto fail
53
-
54
- :findJavaFromJavaHome
55
- set JAVA_HOME=%JAVA_HOME:"=%
56
- set JAVA_EXE=%JAVA_HOME%/bin/java.exe
57
-
58
- if exist "%JAVA_EXE%" goto execute
59
-
60
- echo. 1>&2
61
- echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME% 1>&2
62
- echo. 1>&2
63
- echo Please set the JAVA_HOME variable in your environment to match the 1>&2
64
- echo location of your Java installation. 1>&2
65
-
66
- goto fail
67
-
68
- :execute
69
- @rem Setup the command line
70
-
71
- set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
72
-
73
-
74
- @rem Execute Gradle
75
- "%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %*
76
-
77
- :end
78
- @rem End local scope for the variables with windows NT shell
79
- if %ERRORLEVEL% equ 0 goto mainEnd
80
-
81
- :fail
82
- rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
83
- rem the _cmd.exe /c_ return code!
84
- set EXIT_CODE=%ERRORLEVEL%
85
- if %EXIT_CODE% equ 0 set EXIT_CODE=1
86
- if not ""=="%GRADLE_EXIT_CONSOLE%" exit %EXIT_CODE%
87
- exit /b %EXIT_CODE%
88
-
89
- :mainEnd
90
- if "%OS%"=="Windows_NT" endlocal
91
-
92
- :omega
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
order-service/settings.gradle DELETED
@@ -1 +0,0 @@
1
- rootProject.name = 'order-service'
 
 
order-service/src/main/java/com/order/controller/OrderController.java DELETED
@@ -1,26 +0,0 @@
1
- package com.order.controller;
2
-
3
- import com.order.dto.Order;
4
- import com.order.service.OrderService;
5
- import org.springframework.beans.factory.annotation.Autowired;
6
- import org.springframework.http.HttpStatus;
7
- import org.springframework.http.ResponseEntity;
8
- import org.springframework.web.bind.annotation.*;
9
-
10
- @RestController
11
- @RequestMapping("/orders")
12
- public class OrderController {
13
-
14
- private final OrderService orderService;
15
-
16
- @Autowired
17
- public OrderController(OrderService orderService) {
18
- this.orderService = orderService;
19
- }
20
-
21
- @PostMapping
22
- public ResponseEntity<String> createOrder(@RequestBody Order order) {
23
- orderService.processOrder(order);
24
- return ResponseEntity.status(HttpStatus.CREATED).body("Order created");
25
- }
26
- }
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
order-service/src/main/java/com/order/dto/Order.java DELETED
@@ -1,9 +0,0 @@
1
- package com.order.dto;
2
-
3
- import lombok.Data;
4
-
5
- @Data
6
- public class Order {
7
- private String productId;
8
- private int quantity;
9
- }
 
 
 
 
 
 
 
 
 
 
order-service/src/main/java/com/order/orderservice/OrderServiceApplication.java DELETED
@@ -1,13 +0,0 @@
1
- package com.order.orderservice;
2
-
3
- import org.springframework.boot.SpringApplication;
4
- import org.springframework.boot.autoconfigure.SpringBootApplication;
5
-
6
- @SpringBootApplication
7
- public class OrderServiceApplication {
8
-
9
- public static void main(String[] args) {
10
- SpringApplication.run(OrderServiceApplication.class, args);
11
- }
12
-
13
- }
 
 
 
 
 
 
 
 
 
 
 
 
 
 
order-service/src/main/java/com/order/service/OrderService.java DELETED
@@ -1,21 +0,0 @@
1
- package com.order.service;
2
-
3
- import com.order.dto.Order;
4
- import org.springframework.beans.factory.annotation.Autowired;
5
- import org.springframework.kafka.core.KafkaTemplate;
6
- import org.springframework.stereotype.Service;
7
-
8
- @Service
9
- public class OrderService {
10
-
11
- private final KafkaTemplate<String, Order> kafkaTemplate;
12
-
13
- @Autowired
14
- public OrderService(KafkaTemplate<String, Order> kafkaTemplate) {
15
- this.kafkaTemplate = kafkaTemplate;
16
- }
17
-
18
- public void processOrder(Order order) {
19
- kafkaTemplate.send("order-topic", order);
20
- }
21
- }
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
order-service/src/main/resources/application.yml DELETED
@@ -1,20 +0,0 @@
1
- server:
2
- port: 8080
3
-
4
- spring:
5
- datasource:
6
- url: jdbc:h2:mem:testdb
7
- driverClassName: org.h2.Driver
8
- username: sa
9
- password: password
10
- jpa:
11
- database-platform: org.hibernate.dialect.H2Dialect
12
-
13
- kafka:
14
- bootstrap-servers: kafka:9092
15
- producer:
16
- key-serializer: org.apache.kafka.common.serialization.StringSerializer
17
- value-serializer: org.apache.kafka.common.serialization.StringSerializer
18
- consumer:
19
- group-id: order-group
20
- auto-offset-reset: earliest
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
order-service/src/test/java/com/order/orderservice/OrderServiceApplicationTests.java DELETED
@@ -1,13 +0,0 @@
1
- package com.order.orderservice;
2
-
3
- import org.junit.jupiter.api.Test;
4
- import org.springframework.boot.test.context.SpringBootTest;
5
-
6
- @SpringBootTest
7
- class OrderServiceApplicationTests {
8
-
9
- @Test
10
- void contextLoads() {
11
- }
12
-
13
- }