\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
# Crucial for Schema Registry
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}