blob: 89cf05ab903353f276fe65a63538c025d0b98443 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
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}
|
