summaryrefslogtreecommitdiff
path: root/content/implementation.tex
diff options
context:
space:
mode:
authormjkwiatkowski <mati.rewa@gmail.com>2026-07-04 10:37:33 +0200
committermjkwiatkowski <mati.rewa@gmail.com>2026-07-04 10:37:33 +0200
commit2cd079ce2ac68061b53848f87fa95bf46d717e3a (patch)
tree97d03cec4c156b496c14c9c485d7ffb65eac0f85 /content/implementation.tex
parent585d105e905744802b40b3a7f6c9ba6d87a1f3ad (diff)
feat: finished figure 5.1
Diffstat (limited to 'content/implementation.tex')
-rw-r--r--content/implementation.tex41
1 files changed, 4 insertions, 37 deletions
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}