summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authormjkwiatkowski <mati.rewa@gmail.com>2026-07-03 16:46:07 +0200
committermjkwiatkowski <mati.rewa@gmail.com>2026-07-03 16:46:07 +0200
commit585d105e905744802b40b3a7f6c9ba6d87a1f3ad (patch)
tree2e33f4e96fb5944af07aa26ed0409addbbdcd1ba
parent40c4fe8f8da11603da536a291e44261749860a09 (diff)
feat: added the lslistings for source and sinks for confluent kafka
-rw-r--r--content/implementation.tex36
-rw-r--r--style/style.tex26
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}