From 2cd079ce2ac68061b53848f87fa95bf46d717e3a Mon Sep 17 00:00:00 2001 From: mjkwiatkowski Date: Sat, 4 Jul 2026 10:37:33 +0200 Subject: feat: finished figure 5.1 --- sources/flow_diagram.drawio | 368 ++++++++++++++++++++++---------------------- sources/listings.tex | 33 ++++ 2 files changed, 220 insertions(+), 181 deletions(-) create mode 100644 sources/listings.tex (limited to 'sources') diff --git a/sources/flow_diagram.drawio b/sources/flow_diagram.drawio index 4ba801c..b90053b 100644 --- a/sources/flow_diagram.drawio +++ b/sources/flow_diagram.drawio @@ -1,250 +1,256 @@ - + - - + + - - + + - - + + - - + + - - + + - - - - - + + - - - - - + + - - - - - + + - - - - - + + - - + + - - + + - - + + - - + + - - + + - - + + - - - - - + + - - - - - + + - - - - - + + - - + + - - + + - - - - - + + - - - - - + + - - - - + + + - - - - - + + - - - - - + + - - + + - - + + - - + + - - + + - - + + - - + + - - - - - - - - - + + - - + + - - + + - - + + - - + + - - - - - - - - + + - - + + - - + + - - + + - - + + - - - - - + + - + - - + + - + - - + + - - - - - + + - - - - - + + - - + + - - + + - - + + - - + + - - + + - - + + - - - - - - - - - + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + - - + + - - + + - - + + - - + + 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} -- cgit v1.2.3