diff options
| author | mjkwiatkowski <mati.rewa@gmail.com> | 2026-07-03 16:46:07 +0200 |
|---|---|---|
| committer | mjkwiatkowski <mati.rewa@gmail.com> | 2026-07-03 16:46:07 +0200 |
| commit | 585d105e905744802b40b3a7f6c9ba6d87a1f3ad (patch) | |
| tree | 2e33f4e96fb5944af07aa26ed0409addbbdcd1ba | |
| parent | 40c4fe8f8da11603da536a291e44261749860a09 (diff) | |
feat: added the lslistings for source and sinks for confluent kafka
| -rw-r--r-- | content/implementation.tex | 36 | ||||
| -rw-r--r-- | style/style.tex | 26 |
2 files changed, 61 insertions, 1 deletions
diff --git a/content/implementation.tex b/content/implementation.tex index 86cb72d..d070b1a 100644 --- a/content/implementation.tex +++ b/content/implementation.tex @@ -56,6 +56,42 @@ For a specific overview of advantages of \code{OpenDC} and a thorough comparison \end{figure} \section{Data Flow}\label{ss:data_flow} +\begin{minipage}[b]{0.48\textwidth} + \begin{lstlisting} +name=postgresql-sink +connector.class=io.confluent.connect.jdbc.JdbcSinkConnector +tasks.max=1 +key.converter=org.apache.kafka.connect.storage.StringConverter +value.converter=io.confluent.connect.protobuf.ProtobufConverter +value.converter.schema.registry.url=http://localhost:8081 +topics=postgres_topic +connection.url=jdbc:postgresql://127.0.0.1:5432/opendc +connection.user=matt +connection.password=admin +auto.create=true +auto.evolve=true +insert.mode=insert +table.name.format=postgres_topic + \end{lstlisting} +\end{minipage} +\hspace{0.3cm} +\begin{minipage}[b]{0.48\textwidth} + \begin{lstlisting} +name=kafka-connect-redis +topics=postgres_topic +tasks.max=1 +connector.class=com.redis.kafka.connect.RedisSinkConnector +key.converter=org.apache.kafka.connect.storage.StringConverter +value.converter=io.confluent.connect.protobuf.ProtobufConverter +value.converter.schema.registry.url=http://localhost:8081 +transforms=downtime +transforms.downtime.type=io.confluent.connect.transforms.Filter$Value +transforms.downtime.filter.condition=$[?(@.downtime == '0.0')] +transforms.downtime.filter.type=exclude +transforms.downtime.missing.or.null.behavior=fail + \end{lstlisting} +\end{minipage} +\ipsum[1-2] \section{Programming Effort}\label{ss:programming} diff --git a/style/style.tex b/style/style.tex index 032d0ed..87990f6 100644 --- a/style/style.tex +++ b/style/style.tex @@ -1,7 +1,7 @@ \usepackage[T1]{fontenc} \usepackage[inline]{enumitem} \usepackage[dvipsnames]{xcolor} -\usepackage{xspace,hyperref, lipsum, booktabs, caption, fancyhdr, footmisc, nomencl, rotating, setspace, subfigure,tocbibind, vmargin, watermark, graphicx, pifont, float, array, ipsum, circledsteps, inconsolata} +\usepackage{xspace,hyperref, lipsum, booktabs, caption, fancyhdr, footmisc, nomencl, rotating, setspace, subfigure,tocbibind, vmargin, watermark, graphicx, pifont, float, array, ipsum, circledsteps, inconsolata, listings} \hypersetup { hidelinks=false, @@ -31,4 +31,28 @@ \newcommand{\BibTeX}{\textsc{B\kern-0.1emi\kern-0.017emb}\kern-0.15em\TeX\xspace} +\definecolor{codegreen}{rgb}{0,0.6,0} +\definecolor{codegray}{rgb}{0.2,0.2,0.2} +\definecolor{codepurple}{rgb}{0.58,0,0.82} +\definecolor{backcolour}{rgb}{1.2,1.2,0.95} +\lstdefinestyle{mystyle}{ + backgroundcolor=\color{backcolour}, + commentstyle=\color{codegreen}, + keywordstyle=\color{magenta}, + numberstyle=\tiny\color{codegray}, + stringstyle=\color{codepurple}, + basicstyle=\ttfamily\footnotesize, + breakatwhitespace=false, + breaklines=true, + captionpos=b, + keepspaces=true, + numbers=left, + numbersep=5pt, + showspaces=false, + showstringspaces=false, + showtabs=false, + tabsize=2 +} + +\lstset{style=mystyle} |
