Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
J
Java8Pocs
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Harshitha Sai Muppala
Java8Pocs
Commits
4bb90be0
Commit
4bb90be0
authored
2 years ago
by
Harshitha Sai Muppala
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Added the Order Task
parents
Changes
17
Show whitespace changes
Inline
Side-by-side
Showing
17 changed files
with
970 additions
and
0 deletions
+970
-0
.gitignore
.gitignore
+33
-0
maven-wrapper.jar
.mvn/wrapper/maven-wrapper.jar
+0
-0
maven-wrapper.properties
.mvn/wrapper/maven-wrapper.properties
+18
-0
mvnw
mvnw
+316
-0
mvnw.cmd
mvnw.cmd
+188
-0
pom.xml
pom.xml
+98
-0
KafkaproducerconsumeApplication.java
...kafkaproducerconsume/KafkaproducerconsumeApplication.java
+14
-0
AbstractMongoConfiguration.java
...ucerconsume/configuration/AbstractMongoConfiguration.java
+4
-0
MyMongoConfigs.java
...le/kafkaproducerconsume/configuration/MyMongoConfigs.java
+9
-0
KafkaController.java
...mple/kafkaproducerconsume/controller/KafkaController.java
+57
-0
KafkaEntity.java
.../com/example/kafkaproducerconsume/entity/KafkaEntity.java
+18
-0
KafkaRepository.java
...mple/kafkaproducerconsume/repository/KafkaRepository.java
+12
-0
Consumer.java
...va/com/example/kafkaproducerconsume/service/Consumer.java
+41
-0
KafkaService.java
...om/example/kafkaproducerconsume/service/KafkaService.java
+78
-0
Producer.java
...va/com/example/kafkaproducerconsume/service/Producer.java
+54
-0
application.properties
src/main/resources/application.properties
+17
-0
KafkaproducerconsumeApplicationTests.java
...producerconsume/KafkaproducerconsumeApplicationTests.java
+13
-0
No files found.
.gitignore
0 → 100644
View file @
4bb90be0
HELP.md
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### STS ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
This diff is collapsed.
Click to expand it.
.mvn/wrapper/maven-wrapper.jar
0 → 100644
View file @
4bb90be0
File added
This diff is collapsed.
Click to expand it.
.mvn/wrapper/maven-wrapper.properties
0 → 100644
View file @
4bb90be0
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
distributionUrl
=
https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.8.7/apache-maven-3.8.7-bin.zip
wrapperUrl
=
https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.1/maven-wrapper-3.1.1.jar
This diff is collapsed.
Click to expand it.
mvnw
0 → 100644
View file @
4bb90be0
#!/bin/sh
# ----------------------------------------------------------------------------
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
# ----------------------------------------------------------------------------
# ----------------------------------------------------------------------------
# Maven Start Up Batch script
#
# Required ENV vars:
# ------------------
# JAVA_HOME - location of a JDK home dir
#
# Optional ENV vars
# -----------------
# M2_HOME - location of maven2's installed home dir
# MAVEN_OPTS - parameters passed to the Java VM when running Maven
# e.g. to debug Maven itself, use
# set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
# MAVEN_SKIP_RC - flag to disable loading of mavenrc files
# ----------------------------------------------------------------------------
if
[
-z
"
$MAVEN_SKIP_RC
"
]
;
then
if
[
-f
/usr/local/etc/mavenrc
]
;
then
.
/usr/local/etc/mavenrc
fi
if
[
-f
/etc/mavenrc
]
;
then
.
/etc/mavenrc
fi
if
[
-f
"
$HOME
/.mavenrc"
]
;
then
.
"
$HOME
/.mavenrc"
fi
fi
# OS specific support. $var _must_ be set to either true or false.
cygwin
=
false
;
darwin
=
false
;
mingw
=
false
case
"
`
uname
`
"
in
CYGWIN
*
)
cygwin
=
true
;;
MINGW
*
)
mingw
=
true
;;
Darwin
*
)
darwin
=
true
# Use /usr/libexec/java_home if available, otherwise fall back to /Library/Java/Home
# See https://developer.apple.com/library/mac/qa/qa1170/_index.html
if
[
-z
"
$JAVA_HOME
"
]
;
then
if
[
-x
"/usr/libexec/java_home"
]
;
then
export
JAVA_HOME
=
"
`
/usr/libexec/java_home
`
"
else
export
JAVA_HOME
=
"/Library/Java/Home"
fi
fi
;;
esac
if
[
-z
"
$JAVA_HOME
"
]
;
then
if
[
-r
/etc/gentoo-release
]
;
then
JAVA_HOME
=
`
java-config
--jre-home
`
fi
fi
if
[
-z
"
$M2_HOME
"
]
;
then
## resolve links - $0 may be a link to maven's home
PRG
=
"
$0
"
# need this for relative symlinks
while
[
-h
"
$PRG
"
]
;
do
ls
=
`
ls
-ld
"
$PRG
"
`
link
=
`
expr
"
$ls
"
:
'.*-> \(.*\)$'
`
if
expr
"
$link
"
:
'/.*'
>
/dev/null
;
then
PRG
=
"
$link
"
else
PRG
=
"
`
dirname
"
$PRG
"
`
/
$link
"
fi
done
saveddir
=
`
pwd
`
M2_HOME
=
`
dirname
"
$PRG
"
`
/..
# make it fully qualified
M2_HOME
=
`
cd
"
$M2_HOME
"
&&
pwd
`
cd
"
$saveddir
"
# echo Using m2 at $M2_HOME
fi
# For Cygwin, ensure paths are in UNIX format before anything is touched
if
$cygwin
;
then
[
-n
"
$M2_HOME
"
]
&&
M2_HOME
=
`
cygpath
--unix
"
$M2_HOME
"
`
[
-n
"
$JAVA_HOME
"
]
&&
JAVA_HOME
=
`
cygpath
--unix
"
$JAVA_HOME
"
`
[
-n
"
$CLASSPATH
"
]
&&
CLASSPATH
=
`
cygpath
--path
--unix
"
$CLASSPATH
"
`
fi
# For Mingw, ensure paths are in UNIX format before anything is touched
if
$mingw
;
then
[
-n
"
$M2_HOME
"
]
&&
M2_HOME
=
"
`
(
cd
"
$M2_HOME
"
;
pwd
)
`
"
[
-n
"
$JAVA_HOME
"
]
&&
JAVA_HOME
=
"
`
(
cd
"
$JAVA_HOME
"
;
pwd
)
`
"
fi
if
[
-z
"
$JAVA_HOME
"
]
;
then
javaExecutable
=
"
`
which javac
`
"
if
[
-n
"
$javaExecutable
"
]
&&
!
[
"
`
expr
\"
$javaExecutable
\"
:
'\([^ ]*\)'
`
"
=
"no"
]
;
then
# readlink(1) is not available as standard on Solaris 10.
readLink
=
`
which
readlink
`
if
[
!
`
expr
"
$readLink
"
:
'\([^ ]*\)'
`
=
"no"
]
;
then
if
$darwin
;
then
javaHome
=
"
`
dirname
\"
$javaExecutable
\"
`
"
javaExecutable
=
"
`
cd
\"
$javaHome
\"
&&
pwd
-P
`
/javac"
else
javaExecutable
=
"
`
readlink
-f
\"
$javaExecutable
\"
`
"
fi
javaHome
=
"
`
dirname
\"
$javaExecutable
\"
`
"
javaHome
=
`
expr
"
$javaHome
"
:
'\(.*\)/bin'
`
JAVA_HOME
=
"
$javaHome
"
export
JAVA_HOME
fi
fi
fi
if
[
-z
"
$JAVACMD
"
]
;
then
if
[
-n
"
$JAVA_HOME
"
]
;
then
if
[
-x
"
$JAVA_HOME
/jre/sh/java"
]
;
then
# IBM's JDK on AIX uses strange locations for the executables
JAVACMD
=
"
$JAVA_HOME
/jre/sh/java"
else
JAVACMD
=
"
$JAVA_HOME
/bin/java"
fi
else
JAVACMD
=
"
`
\\
unset
-f
command
;
\\
command
-v
java
`
"
fi
fi
if
[
!
-x
"
$JAVACMD
"
]
;
then
echo
"Error: JAVA_HOME is not defined correctly."
>
&2
echo
" We cannot execute
$JAVACMD
"
>
&2
exit
1
fi
if
[
-z
"
$JAVA_HOME
"
]
;
then
echo
"Warning: JAVA_HOME environment variable is not set."
fi
CLASSWORLDS_LAUNCHER
=
org.codehaus.plexus.classworlds.launcher.Launcher
# traverses directory structure from process work directory to filesystem root
# first directory with .mvn subdirectory is considered project base directory
find_maven_basedir
()
{
if
[
-z
"
$1
"
]
then
echo
"Path not specified to find_maven_basedir"
return
1
fi
basedir
=
"
$1
"
wdir
=
"
$1
"
while
[
"
$wdir
"
!=
'/'
]
;
do
if
[
-d
"
$wdir
"
/.mvn
]
;
then
basedir
=
$wdir
break
fi
# workaround for JBEAP-8937 (on Solaris 10/Sparc)
if
[
-d
"
${
wdir
}
"
]
;
then
wdir
=
`
cd
"
$wdir
/.."
;
pwd
`
fi
# end of workaround
done
echo
"
${
basedir
}
"
}
# concatenates all lines of a file
concat_lines
()
{
if
[
-f
"
$1
"
]
;
then
echo
"
$(
tr
-s
'\n'
' '
<
"
$1
"
)
"
fi
}
BASE_DIR
=
`
find_maven_basedir
"
$(
pwd
)
"
`
if
[
-z
"
$BASE_DIR
"
]
;
then
exit
1
;
fi
##########################################################################################
# Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
# This allows using the maven wrapper in projects that prohibit checking in binary data.
##########################################################################################
if
[
-r
"
$BASE_DIR
/.mvn/wrapper/maven-wrapper.jar"
]
;
then
if
[
"
$MVNW_VERBOSE
"
=
true
]
;
then
echo
"Found .mvn/wrapper/maven-wrapper.jar"
fi
else
if
[
"
$MVNW_VERBOSE
"
=
true
]
;
then
echo
"Couldn't find .mvn/wrapper/maven-wrapper.jar, downloading it ..."
fi
if
[
-n
"
$MVNW_REPOURL
"
]
;
then
jarUrl
=
"
$MVNW_REPOURL
/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
else
jarUrl
=
"https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
fi
while
IFS
=
"="
read
key value
;
do
case
"
$key
"
in
(
wrapperUrl
)
jarUrl
=
"
$value
"
;
break
;;
esac
done
<
"
$BASE_DIR
/.mvn/wrapper/maven-wrapper.properties"
if
[
"
$MVNW_VERBOSE
"
=
true
]
;
then
echo
"Downloading from:
$jarUrl
"
fi
wrapperJarPath
=
"
$BASE_DIR
/.mvn/wrapper/maven-wrapper.jar"
if
$cygwin
;
then
wrapperJarPath
=
`
cygpath
--path
--windows
"
$wrapperJarPath
"
`
fi
if
command
-v
wget
>
/dev/null
;
then
if
[
"
$MVNW_VERBOSE
"
=
true
]
;
then
echo
"Found wget ... using wget"
fi
if
[
-z
"
$MVNW_USERNAME
"
]
||
[
-z
"
$MVNW_PASSWORD
"
]
;
then
wget
"
$jarUrl
"
-O
"
$wrapperJarPath
"
||
rm
-f
"
$wrapperJarPath
"
else
wget
--http-user
=
$MVNW_USERNAME
--http-password
=
$MVNW_PASSWORD
"
$jarUrl
"
-O
"
$wrapperJarPath
"
||
rm
-f
"
$wrapperJarPath
"
fi
elif
command
-v
curl
>
/dev/null
;
then
if
[
"
$MVNW_VERBOSE
"
=
true
]
;
then
echo
"Found curl ... using curl"
fi
if
[
-z
"
$MVNW_USERNAME
"
]
||
[
-z
"
$MVNW_PASSWORD
"
]
;
then
curl
-o
"
$wrapperJarPath
"
"
$jarUrl
"
-f
else
curl
--user
$MVNW_USERNAME
:
$MVNW_PASSWORD
-o
"
$wrapperJarPath
"
"
$jarUrl
"
-f
fi
else
if
[
"
$MVNW_VERBOSE
"
=
true
]
;
then
echo
"Falling back to using Java to download"
fi
javaClass
=
"
$BASE_DIR
/.mvn/wrapper/MavenWrapperDownloader.java"
# For Cygwin, switch paths to Windows format before running javac
if
$cygwin
;
then
javaClass
=
`
cygpath
--path
--windows
"
$javaClass
"
`
fi
if
[
-e
"
$javaClass
"
]
;
then
if
[
!
-e
"
$BASE_DIR
/.mvn/wrapper/MavenWrapperDownloader.class"
]
;
then
if
[
"
$MVNW_VERBOSE
"
=
true
]
;
then
echo
" - Compiling MavenWrapperDownloader.java ..."
fi
# Compiling the Java class
(
"
$JAVA_HOME
/bin/javac"
"
$javaClass
"
)
fi
if
[
-e
"
$BASE_DIR
/.mvn/wrapper/MavenWrapperDownloader.class"
]
;
then
# Running the downloader
if
[
"
$MVNW_VERBOSE
"
=
true
]
;
then
echo
" - Running MavenWrapperDownloader.java ..."
fi
(
"
$JAVA_HOME
/bin/java"
-cp
.mvn/wrapper MavenWrapperDownloader
"
$MAVEN_PROJECTBASEDIR
"
)
fi
fi
fi
fi
##########################################################################################
# End of extension
##########################################################################################
export
MAVEN_PROJECTBASEDIR
=
${
MAVEN_BASEDIR
:-
"
$BASE_DIR
"
}
if
[
"
$MVNW_VERBOSE
"
=
true
]
;
then
echo
$MAVEN_PROJECTBASEDIR
fi
MAVEN_OPTS
=
"
$(
concat_lines
"
$MAVEN_PROJECTBASEDIR
/.mvn/jvm.config"
)
$MAVEN_OPTS
"
# For Cygwin, switch paths to Windows format before running java
if
$cygwin
;
then
[
-n
"
$M2_HOME
"
]
&&
M2_HOME
=
`
cygpath
--path
--windows
"
$M2_HOME
"
`
[
-n
"
$JAVA_HOME
"
]
&&
JAVA_HOME
=
`
cygpath
--path
--windows
"
$JAVA_HOME
"
`
[
-n
"
$CLASSPATH
"
]
&&
CLASSPATH
=
`
cygpath
--path
--windows
"
$CLASSPATH
"
`
[
-n
"
$MAVEN_PROJECTBASEDIR
"
]
&&
MAVEN_PROJECTBASEDIR
=
`
cygpath
--path
--windows
"
$MAVEN_PROJECTBASEDIR
"
`
fi
# Provide a "standardized" way to retrieve the CLI args that will
# work with both Windows and non-Windows executions.
MAVEN_CMD_LINE_ARGS
=
"
$MAVEN_CONFIG
$@
"
export
MAVEN_CMD_LINE_ARGS
WRAPPER_LAUNCHER
=
org.apache.maven.wrapper.MavenWrapperMain
exec
"
$JAVACMD
"
\
$MAVEN_OPTS
\
$MAVEN_DEBUG_OPTS
\
-classpath
"
$MAVEN_PROJECTBASEDIR
/.mvn/wrapper/maven-wrapper.jar"
\
"-Dmaven.home=
${
M2_HOME
}
"
\
"-Dmaven.multiModuleProjectDirectory=
${
MAVEN_PROJECTBASEDIR
}
"
\
${
WRAPPER_LAUNCHER
}
$MAVEN_CONFIG
"
$@
"
This diff is collapsed.
Click to expand it.
mvnw.cmd
0 → 100644
View file @
4bb90be0
@REM ----------------------------------------------------------------------------
@REM Licensed to the Apache Software Foundation (ASF) under one
@REM or more contributor license agreements. See the NOTICE file
@REM distributed with this work for additional information
@REM regarding copyright ownership. The ASF licenses this file
@REM to you under the Apache License, Version 2.0 (the
@REM "License"); you may not use this file except in compliance
@REM with the License. You may obtain a copy of the License at
@REM
@REM https://www.apache.org/licenses/LICENSE-2.0
@REM
@REM Unless required by applicable law or agreed to in writing,
@REM software distributed under the License is distributed on an
@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@REM KIND, either express or implied. See the License for the
@REM specific language governing permissions and limitations
@REM under the License.
@REM ----------------------------------------------------------------------------
@REM ----------------------------------------------------------------------------
@REM Maven Start Up Batch script
@REM
@REM Required ENV vars:
@REM JAVA_HOME - location of a JDK home dir
@REM
@REM Optional ENV vars
@REM M2_HOME - location of maven2's installed home dir
@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending
@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
@REM e.g. to debug Maven itself, use
@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
@REM ----------------------------------------------------------------------------
@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
@echo off
@REM set title of command window
title %0
@REM enable echoing by setting MAVEN_BATCH_ECHO to 'on'
@if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO%
@REM set %HOME% to equivalent of $HOME
if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
@REM Execute a user defined script before this one
if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
@REM check for pre script, once with legacy .bat ending and once with .cmd ending
if exist "%USERPROFILE%\mavenrc_pre.bat" call "%USERPROFILE%\mavenrc_pre.bat" %*
if exist "%USERPROFILE%\mavenrc_pre.cmd" call "%USERPROFILE%\mavenrc_pre.cmd" %*
:skipRcPre
@setlocal
set ERROR_CODE=0
@REM To isolate internal variables from possible post scripts, we use another setlocal
@setlocal
@REM ==== START VALIDATION ====
if not "%JAVA_HOME%" == "" goto OkJHome
echo.
echo Error: JAVA_HOME not found in your environment. >&2
echo Please set the JAVA_HOME variable in your environment to match the >&2
echo location of your Java installation. >&2
echo.
goto error
:OkJHome
if exist "%JAVA_HOME%\bin\java.exe" goto init
echo.
echo Error: JAVA_HOME is set to an invalid directory. >&2
echo JAVA_HOME = "%JAVA_HOME%" >&2
echo Please set the JAVA_HOME variable in your environment to match the >&2
echo location of your Java installation. >&2
echo.
goto error
@REM ==== END VALIDATION ====
:init
@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
@REM Fallback to current working directory if not found.
set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
set EXEC_DIR=%CD%
set WDIR=%EXEC_DIR%
:findBaseDir
IF EXIST "%WDIR%"\.mvn goto baseDirFound
cd ..
IF "%WDIR%"=="%CD%" goto baseDirNotFound
set WDIR=%CD%
goto findBaseDir
:baseDirFound
set MAVEN_PROJECTBASEDIR=%WDIR%
cd "%EXEC_DIR%"
goto endDetectBaseDir
:baseDirNotFound
set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
cd "%EXEC_DIR%"
:endDetectBaseDir
IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
@setlocal EnableExtensions EnableDelayedExpansion
for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
:endReadAdditionalConfig
SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
set DOWNLOAD_URL="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
IF "%%A"=="wrapperUrl" SET DOWNLOAD_URL=%%B
)
@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
@REM This allows using the maven wrapper in projects that prohibit checking in binary data.
if exist %WRAPPER_JAR% (
if "%MVNW_VERBOSE%" == "true" (
echo Found %WRAPPER_JAR%
)
) else (
if not "%MVNW_REPOURL%" == "" (
SET DOWNLOAD_URL="%MVNW_REPOURL%/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
)
if "%MVNW_VERBOSE%" == "true" (
echo Couldn't find %WRAPPER_JAR%, downloading it ...
echo Downloading from: %DOWNLOAD_URL%
)
powershell -Command "&{"^
"$webclient = new-object System.Net.WebClient;"^
"if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^
"$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^
"}"^
"[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%DOWNLOAD_URL%', '%WRAPPER_JAR%')"^
"}"
if "%MVNW_VERBOSE%" == "true" (
echo Finished downloading %WRAPPER_JAR%
)
)
@REM End of extension
@REM Provide a "standardized" way to retrieve the CLI args that will
@REM work with both Windows and non-Windows executions.
set MAVEN_CMD_LINE_ARGS=%*
%MAVEN_JAVA_EXE% ^
%JVM_CONFIG_MAVEN_PROPS% ^
%MAVEN_OPTS% ^
%MAVEN_DEBUG_OPTS% ^
-classpath %WRAPPER_JAR% ^
"-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" ^
%WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
if ERRORLEVEL 1 goto error
goto end
:error
set ERROR_CODE=1
:end
@endlocal & set ERROR_CODE=%ERROR_CODE%
if not "%MAVEN_SKIP_RC%"=="" goto skipRcPost
@REM check for post script, once with legacy .bat ending and once with .cmd ending
if exist "%USERPROFILE%\mavenrc_post.bat" call "%USERPROFILE%\mavenrc_post.bat"
if exist "%USERPROFILE%\mavenrc_post.cmd" call "%USERPROFILE%\mavenrc_post.cmd"
:skipRcPost
@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
if "%MAVEN_BATCH_PAUSE%"=="on" pause
if "%MAVEN_TERMINATE_CMD%"=="on" exit %ERROR_CODE%
cmd /C exit /B %ERROR_CODE%
This diff is collapsed.
Click to expand it.
pom.xml
0 → 100644
View file @
4bb90be0
<?xml version="1.0" encoding="UTF-8"?>
<project
xmlns=
"http://maven.apache.org/POM/4.0.0"
xmlns:xsi=
"http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation=
"http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"
>
<modelVersion>
4.0.0
</modelVersion>
<parent>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
spring-boot-starter-parent
</artifactId>
<version>
3.0.5
</version>
<relativePath/>
<!-- lookup parent from repository -->
</parent>
<groupId>
com.example
</groupId>
<artifactId>
kafkaproducerconsume
</artifactId>
<version>
0.0.1-SNAPSHOT
</version>
<name>
kafkaproducerconsume
</name>
<description>
Demo project for Spring Boot
</description>
<properties>
<java.version>
17
</java.version>
</properties>
<dependencies>
<dependency>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
spring-boot-starter-web
</artifactId>
</dependency>
<dependency>
<groupId>
org.springframework.kafka
</groupId>
<artifactId>
spring-kafka
</artifactId>
</dependency>
<dependency>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
spring-boot-starter-test
</artifactId>
<scope>
test
</scope>
</dependency>
<dependency>
<groupId>
org.springframework.kafka
</groupId>
<artifactId>
spring-kafka-test
</artifactId>
<scope>
test
</scope>
</dependency>
<dependency>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
spring-boot-starter-data-mongodb
</artifactId>
</dependency>
<dependency>
<groupId>
com.google.cloud
</groupId>
<artifactId>
google-cloud-core
</artifactId>
<version>
1.95.0
</version>
</dependency>
<dependency>
<groupId>
org.projectlombok
</groupId>
<artifactId>
lombok
</artifactId>
<optional>
true
</optional>
</dependency>
<dependency>
<groupId>
com.albertsons.ecommerce
</groupId>
<artifactId>
OSCO-DataModel
</artifactId>
<version>
rel-1.1-23.04.02-31
</version>
<scope>
system
</scope>
<systemPath>
D:/jar/OSCO-DataModel-rel-1.1-23.04.02-31.jar
</systemPath>
</dependency>
<dependency>
<groupId>
com.fasterxml.jackson.core
</groupId>
<artifactId>
jackson-databind
</artifactId>
<version>
2.12.5
</version>
</dependency>
<dependency>
<groupId>
com.fasterxml.jackson.core
</groupId>
<artifactId>
jackson-annotations
</artifactId>
<version>
2.12.5
</version>
</dependency>
<dependency>
<groupId>
com.fasterxml.jackson.core
</groupId>
<artifactId>
jackson-core
</artifactId>
<version>
2.12.5
</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-api -->
<dependency>
<groupId>
org.slf4j
</groupId>
<artifactId>
slf4j-api
</artifactId>
<version>
2.0.7
</version>
</dependency>
<dependency>
<groupId>
org.mongodb
</groupId>
<artifactId>
mongodb-driver
</artifactId>
<version>
3.3.0
</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
spring-boot-maven-plugin
</artifactId>
</plugin>
</plugins>
</build>
</project>
This diff is collapsed.
Click to expand it.
src/main/java/com/example/kafkaproducerconsume/KafkaproducerconsumeApplication.java
0 → 100644
View file @
4bb90be0
package
com
.
example
.
kafkaproducerconsume
;
import
org.springframework.boot.SpringApplication
;
import
org.springframework.boot.autoconfigure.SpringBootApplication
;
@SpringBootApplication
public
class
KafkaproducerconsumeApplication
{
public
static
void
main
(
String
[]
args
)
{
SpringApplication
.
run
(
KafkaproducerconsumeApplication
.
class
,
args
);
}
}
This diff is collapsed.
Click to expand it.
src/main/java/com/example/kafkaproducerconsume/configuration/AbstractMongoConfiguration.java
0 → 100644
View file @
4bb90be0
package
com
.
example
.
kafkaproducerconsume
.
configuration
;
public
class
AbstractMongoConfiguration
{
}
This diff is collapsed.
Click to expand it.
src/main/java/com/example/kafkaproducerconsume/configuration/MyMongoConfigs.java
0 → 100644
View file @
4bb90be0
package
com
.
example
.
kafkaproducerconsume
.
configuration
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.mongodb.config.AbstractReactiveMongoConfiguration
;
@Configuration
public
class
MyMongoConfigs
extends
AbstractMongoConfiguration
{
}
This diff is collapsed.
Click to expand it.
src/main/java/com/example/kafkaproducerconsume/controller/KafkaController.java
0 → 100644
View file @
4bb90be0
package
com
.
example
.
kafkaproducerconsume
.
controller
;
import
com.albertsons.ecommerce.oms.model.core.Order
;
import
com.example.kafkaproducerconsume.entity.KafkaEntity
;
import
com.example.kafkaproducerconsume.service.KafkaService
;
import
com.example.kafkaproducerconsume.service.Producer
;
import
com.fasterxml.jackson.core.JsonProcessingException
;
import
com.mongodb.client.FindIterable
;
import
org.bson.BsonDocument
;
import
org.slf4j.Logger
;
import
org.slf4j.LoggerFactory
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.bson.Document
;
import
org.springframework.http.HttpStatus
;
import
org.springframework.http.ResponseEntity
;
import
org.springframework.web.bind.annotation.*
;
import
java.util.List
;
import
java.util.Map
;
@RestController
public
class
KafkaController
{
@Autowired
private
KafkaService
kafkaService
;
@Autowired
Producer
producer
;
Logger
logger
=
LoggerFactory
.
getLogger
(
KafkaController
.
class
);
// @PostMapping(value="/post")
// public void sendMessage(@RequestBody KafkaEntity msg) throws JsonProcessingException {
//
// producer.publishToTopic(msg);
// }
// @GetMapping(value="/Id")
// public void getmessage(@RequestParam("id") int id) throws JsonProcessingException {
// producer.publish2(id);
// }
//
// @PostMapping(value="/postt")
// public void savemessage(@RequestBody KafkaEntity msg) throws JsonProcessingException {
// producer.publish1(msg);
// }
@GetMapping
(
"/PublishDeliveryOrders"
)
public
ResponseEntity
<
List
<
String
>>
filterData
()
{
List
<
String
>
ordersWithAdditionalFields
=
kafkaService
.
getFilteredOrders
();
return
new
ResponseEntity
<>(
ordersWithAdditionalFields
,
HttpStatus
.
OK
);
}
}
//http://localhost:8888/post?msg=Happy <=give this message format to URL in the postman
This diff is collapsed.
Click to expand it.
src/main/java/com/example/kafkaproducerconsume/entity/KafkaEntity.java
0 → 100644
View file @
4bb90be0
package
com
.
example
.
kafkaproducerconsume
.
entity
;
import
lombok.AllArgsConstructor
;
import
lombok.Getter
;
import
lombok.NoArgsConstructor
;
import
lombok.Setter
;
import
org.springframework.data.annotation.Id
;
@NoArgsConstructor
@AllArgsConstructor
@Getter
@Setter
public
class
KafkaEntity
{
@Id
private
int
id
;
private
String
message
;
}
This diff is collapsed.
Click to expand it.
src/main/java/com/example/kafkaproducerconsume/repository/KafkaRepository.java
0 → 100644
View file @
4bb90be0
package
com
.
example
.
kafkaproducerconsume
.
repository
;
import
com.example.kafkaproducerconsume.entity.KafkaEntity
;
import
org.springframework.data.mongodb.repository.MongoRepository
;
import
org.springframework.stereotype.Repository
;
@Repository
public
interface
KafkaRepository
extends
MongoRepository
<
KafkaEntity
,
String
>
{
KafkaEntity
findById
(
int
id
);
}
This diff is collapsed.
Click to expand it.
src/main/java/com/example/kafkaproducerconsume/service/Consumer.java
0 → 100644
View file @
4bb90be0
package
com
.
example
.
kafkaproducerconsume
.
service
;
import
com.example.kafkaproducerconsume.KafkaproducerconsumeApplication
;
import
com.example.kafkaproducerconsume.entity.KafkaEntity
;
import
org.slf4j.Logger
;
import
org.slf4j.LoggerFactory
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.kafka.annotation.KafkaListener
;
import
org.springframework.kafka.core.KafkaTemplate
;
import
org.springframework.stereotype.Service
;
@Service
public
class
Consumer
{
Logger
logger
=
LoggerFactory
.
getLogger
(
KafkaproducerconsumeApplication
.
class
);
public
static
final
String
consumedTopic
=
"mytopic6"
;
public
static
final
String
publishedTopic
=
"mytopic7"
;
private
final
KafkaService
kafkaService
;
private
final
KafkaTemplate
<
String
,
KafkaEntity
>
kafkaTemplate
;
@Autowired
public
Consumer
(
KafkaService
kafkaService
,
KafkaTemplate
<
String
,
KafkaEntity
>
kafkaTemplate
)
{
this
.
kafkaService
=
kafkaService
;
this
.
kafkaTemplate
=
kafkaTemplate
;
}
@KafkaListener
(
topics
=
{
consumedTopic
},
groupId
=
"mygroup"
)
public
void
consumeFromTopic
(
KafkaEntity
message
)
{
logger
.
info
(
"Consumed message: "
+
message
.
getMessage
());
kafkaService
.
save
(
message
);
publishToTopic
(
message
);
}
private
void
publishToTopic
(
KafkaEntity
message
)
{
logger
.
info
(
"Publishing to topic: "
+
publishedTopic
);
this
.
kafkaTemplate
.
send
(
publishedTopic
,
message
);
}
}
This diff is collapsed.
Click to expand it.
src/main/java/com/example/kafkaproducerconsume/service/KafkaService.java
0 → 100644
View file @
4bb90be0
package
com
.
example
.
kafkaproducerconsume
.
service
;
import
com.albertsons.ecommerce.oms.model.core.Order
;
import
com.albertsons.ecommerce.oms.model.enums.OrderMode
;
import
com.example.kafkaproducerconsume.entity.KafkaEntity
;
import
com.example.kafkaproducerconsume.repository.KafkaRepository
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.data.mongodb.core.MongoTemplate
;
import
org.springframework.data.mongodb.core.mapping.Document
;
import
org.springframework.data.mongodb.core.query.Criteria
;
import
org.springframework.data.mongodb.core.query.Query
;
import
org.springframework.stereotype.Service
;
import
java.util.*
;
import
java.util.stream.Collectors
;
@Service
public
class
KafkaService
{
@Autowired
private
KafkaRepository
repo
;
public
void
save
(
KafkaEntity
message
)
{
repo
.
save
(
message
);
}
public
KafkaEntity
get
(
int
id
)
{
return
repo
.
findById
(
id
);
}
@Autowired
private
MongoTemplate
mongoTemplate
;
@Autowired
public
KafkaService
(
MongoTemplate
mongoTemplate
)
{
this
.
mongoTemplate
=
mongoTemplate
;
}
public
List
<
String
>
getFilteredOrders
()
{
Query
query
=
Query
.
query
(
Criteria
.
where
(
"orderStatus"
).
is
(
"PAYMENT_REQUESTED"
))
.
addCriteria
(
Criteria
.
where
(
"isActive"
).
is
(
true
))
.
addCriteria
(
Criteria
.
where
(
"subOrders.subOrderType.isRescheduled"
).
is
(
true
));
List
<
Order
>
filteredOrders
=
mongoTemplate
.
find
(
query
,
Order
.
class
);
return
filteredOrders
.
stream
().
filter
(
order
->
Objects
.
nonNull
(
order
.
getOrderNumber
())
&&
Objects
.
nonNull
(
order
.
getStoreNumber
()))
.
map
(
Order:
:
getBanner
)
.
collect
(
Collectors
.
toList
());
// List<Map<String, Object>> ordersWithAdditionalFields = new ArrayList<>();
// for (Order order : filteredOrders) {
// String orderNumber = order.getOrderNumber();
// String storeNumber = order.getStoreNumber();
//
// Map<String, Object> orderWithAdditionalFields = new HashMap<>();
// orderWithAdditionalFields.put("orderNumber", orderNumber);
// orderWithAdditionalFields.put("storeNumber", storeNumber);
// orderWithAdditionalFields.put("banner", order.getBanner());
// orderWithAdditionalFields.put("versionNumber", order.getVersionNumber());
// orderWithAdditionalFields.put("orderStatus", order.getOrderStatus());
//
// ordersWithAdditionalFields.add(orderWithAdditionalFields);
// }
//
// return ordersWithAdditionalFields;
}
}
This diff is collapsed.
Click to expand it.
src/main/java/com/example/kafkaproducerconsume/service/Producer.java
0 → 100644
View file @
4bb90be0
package
com
.
example
.
kafkaproducerconsume
.
service
;
import
com.example.kafkaproducerconsume.KafkaproducerconsumeApplication
;
import
com.example.kafkaproducerconsume.entity.KafkaEntity
;
import
com.fasterxml.jackson.core.JsonProcessingException
;
import
com.fasterxml.jackson.databind.ObjectMapper
;
import
org.slf4j.Logger
;
import
org.slf4j.LoggerFactory
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.kafka.core.KafkaTemplate
;
import
org.springframework.stereotype.Service
;
@Service
public
class
Producer
{
Logger
logger
=
LoggerFactory
.
getLogger
(
KafkaproducerconsumeApplication
.
class
);
public
static
final
String
topic1
=
"mytopic6"
;
public
static
final
String
topic2
=
"mytopic7"
;
private
final
KafkaService
kafkaService
;
private
final
KafkaTemplate
<
String
,
String
>
kafkaTemplate
;
private
final
ObjectMapper
objectMapper
;
@Autowired
public
Producer
(
KafkaService
kafkaService
,
KafkaTemplate
<
String
,
String
>
kafkaTemplate
,
ObjectMapper
objectMapper
)
{
this
.
kafkaService
=
kafkaService
;
this
.
kafkaTemplate
=
kafkaTemplate
;
this
.
objectMapper
=
objectMapper
;
}
public
void
publishToTopic
(
KafkaEntity
message
)
throws
JsonProcessingException
{
logger
.
info
(
"Publishing to topic: "
+
topic1
);
String
jsonMessage
=
objectMapper
.
writeValueAsString
(
message
);
this
.
kafkaTemplate
.
send
(
topic1
,
jsonMessage
);
}
public
void
publish1
(
KafkaEntity
message1
)
throws
JsonProcessingException
{
kafkaService
.
save
(
message1
);
logger
.
info
(
"Publishing to topic: "
+
topic2
);
String
jsonMessage
=
objectMapper
.
writeValueAsString
(
message1
);
this
.
kafkaTemplate
.
send
(
topic2
,
jsonMessage
);
}
public
void
publish2
(
Integer
id
)
throws
JsonProcessingException
{
KafkaEntity
entity
=
kafkaService
.
get
(
id
);
if
(
entity
!=
null
)
{
logger
.
info
(
"Publishing to topic: "
+
topic2
);
String
jsonMessage
=
objectMapper
.
writeValueAsString
(
entity
);
this
.
kafkaTemplate
.
send
(
topic2
,
jsonMessage
);
}
}
}
This diff is collapsed.
Click to expand it.
src/main/resources/application.properties
0 → 100644
View file @
4bb90be0
server.port
=
8888
spring.kafka.consumer.bootstrap-servers
=
localhost:9092
spring.kafka.consumer.group-id
=
mygroup
spring.kafka.consumer.auto-offset-reset
=
earliest
spring.kafka.consumer.key-deserializer
=
org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer
=
org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.producer.bootstrap-servers
=
localhost:9092
spring.kafka.producer.key-serializer
:
org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer
:
org.springframework.kafka.support.serializer.JsonSerializer
spring.data.mongodb.database
=
Kafkamsgdb
spring.data.mongodb.host
=
localhost
spring.data.mongodb.port
=
27017
\ No newline at end of file
This diff is collapsed.
Click to expand it.
src/test/java/com/example/kafkaproducerconsume/KafkaproducerconsumeApplicationTests.java
0 → 100644
View file @
4bb90be0
//package com.example.kafkaproducerconsume;
//
//import org.junit.jupiter.api.Test;
//import org.springframework.boot.test.context.SpringBootTest;
//
//@SpringBootTest
//class KafkaproducerconsumeApplicationTests {
//
// @Test
// void contextLoads() {
// }
//
//}
This diff is collapsed.
Click to expand it.
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment