diff options
Diffstat (limited to 'content/implementation.tex')
| -rw-r--r-- | content/implementation.tex | 36 |
1 files changed, 36 insertions, 0 deletions
diff --git a/content/implementation.tex b/content/implementation.tex index 86cb72d..d070b1a 100644 --- a/content/implementation.tex +++ b/content/implementation.tex @@ -56,6 +56,42 @@ For a specific overview of advantages of \code{OpenDC} and a thorough comparison \end{figure} \section{Data Flow}\label{ss:data_flow} +\begin{minipage}[b]{0.48\textwidth} + \begin{lstlisting} +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} +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} +\ipsum[1-2] \section{Programming Effort}\label{ss:programming} |