From 2cd079ce2ac68061b53848f87fa95bf46d717e3a Mon Sep 17 00:00:00 2001 From: mjkwiatkowski Date: Sat, 4 Jul 2026 10:37:33 +0200 Subject: feat: finished figure 5.1 --- content/implementation.tex | 41 +---- images/flow_diagram.pdf | Bin 42767 -> 55353 bytes images/flow_diagram.png | Bin 0 -> 474395 bytes sources/flow_diagram.drawio | 368 ++++++++++++++++++++++---------------------- sources/listings.tex | 33 ++++ style/style.tex | 4 +- 6 files changed, 226 insertions(+), 220 deletions(-) create mode 100644 images/flow_diagram.png create mode 100644 sources/listings.tex diff --git a/content/implementation.tex b/content/implementation.tex index d070b1a..d5dd5c1 100644 --- a/content/implementation.tex +++ b/content/implementation.tex @@ -50,48 +50,15 @@ For a specific overview of advantages of \code{OpenDC} and a thorough comparison \begin{figure}[t] \centering - \includegraphics[width=\linewidth]{images/flow_diagram.pdf} - \caption{The data flow within \gls{my_system} (work under progress).} + \includegraphics[width=\linewidth]{images/flow_diagram.png} + \caption{The data flow within \gls{my_system}.} \label{fig:flow_diagram} \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} +\input{sources/listings.tex} \ipsum[1-2] + \section{Programming Effort}\label{ss:programming} diff --git a/images/flow_diagram.pdf b/images/flow_diagram.pdf index 7c8cff8..23ed41d 100644 Binary files a/images/flow_diagram.pdf and b/images/flow_diagram.pdf differ diff --git a/images/flow_diagram.png b/images/flow_diagram.png new file mode 100644 index 0000000..d5ae2e8 Binary files /dev/null and b/images/flow_diagram.png differ diff --git a/sources/flow_diagram.drawio b/sources/flow_diagram.drawio index 4ba801c..b90053b 100644 --- a/sources/flow_diagram.drawio +++ b/sources/flow_diagram.drawio @@ -1,250 +1,256 @@ - + - - + + - - + + - - + + - - + + - - + + - - - - - + + - - - - - + + - - - - - + + - - - - - + + - - + + - - + + - - + + - - + + - - + + - - + + - - - - - + + - - - - - + + - - - - - + + - - + + - - + + - - - - - + + - - - - - + + - - - - + + + - - - - - + + - - - - - + + - - + + - - + + - - + + - - + + - - + + - - + + - - - - - - - - - + + - - + + - - + + - - + + - - + + - - - - - - - - + + - - + + - - + + - - + + - - + + - - - - - + + - + - - + + - + - - + + - - - - - + + - - - - - + + - - + + - - + + - - + + - - + + - - + + - - + + - - - - - - - - - + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + - - + + - - + + - - + + - - + + diff --git a/sources/listings.tex b/sources/listings.tex new file mode 100644 index 0000000..89cf05a --- /dev/null +++ b/sources/listings.tex @@ -0,0 +1,33 @@ +\begin{minipage}[b]{0.48\textwidth} + \begin{lstlisting}[caption=Kafka PostgreSQL sink., label={lst:postgresql-sink}] +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}[caption=Kafka Redis sink., label={lst:redis-sink}] +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} diff --git a/style/style.tex b/style/style.tex index 87990f6..f1b06a1 100644 --- a/style/style.tex +++ b/style/style.tex @@ -34,13 +34,13 @@ \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} +\definecolor{backcolour}{rgb}{0.94,0.9725,1} \lstdefinestyle{mystyle}{ backgroundcolor=\color{backcolour}, commentstyle=\color{codegreen}, keywordstyle=\color{magenta}, - numberstyle=\tiny\color{codegray}, + numberstyle=\sffamily\tiny\color{codegray}, stringstyle=\color{codepurple}, basicstyle=\ttfamily\footnotesize, breakatwhitespace=false, -- cgit v1.2.3