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