From 5c7c9cb70fa2de6dfcd92aebdb2f48b09bbd79e1 Mon Sep 17 00:00:00 2001 From: mjkwiatkowski Date: Sat, 4 Jul 2026 10:49:21 +0200 Subject: feat: added the database schema --- sources/listings.tex | 33 --------------------------------- 1 file changed, 33 deletions(-) delete mode 100644 sources/listings.tex (limited to 'sources/listings.tex') diff --git a/sources/listings.tex b/sources/listings.tex deleted file mode 100644 index 89cf05a..0000000 --- a/sources/listings.tex +++ /dev/null @@ -1,33 +0,0 @@ -\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