From 5c7c9cb70fa2de6dfcd92aebdb2f48b09bbd79e1 Mon Sep 17 00:00:00 2001
From: mjkwiatkowski <mati.rewa@gmail.com>
Date: Sat, 4 Jul 2026 10:49:21 +0200
Subject: feat: added the database schema

---
 sources/listing_sinks.tex | 33 +++++++++++++++++++++++++++++++++
 1 file changed, 33 insertions(+)
 create mode 100644 sources/listing_sinks.tex

(limited to 'sources/listing_sinks.tex')

diff --git a/sources/listing_sinks.tex b/sources/listing_sinks.tex
new file mode 100644
index 0000000..89cf05a
--- /dev/null
+++ b/sources/listing_sinks.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}
-- 
cgit v1.2.3

