feat: added the lslistings for source and sinks for confluent kafka

1 files changed, 36 insertions, 0 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}