com.networknt.eventuate.debezium

Class EventTableChangesToAggregateTopicRelayPostgres

java.lang.Object

com.networknt.eventuate.debezium.EventTableChangesToAggregateTopicRelay

com.networknt.eventuate.debezium.EventTableChangesToAggregateTopicRelayPostgres

All Implemented Interfaces:

TableChangeToTopicRelay

public class EventTableChangesToAggregateTopicRelayPostgres
extends EventTableChangesToAggregateTopicRelay

Subscribes to changes made to EVENTS table and publishes them to aggregate topics

Field Summary

Fields inherited from class com.networknt.eventuate.debezium.EventTableChangesToAggregateTopicRelay

dbHost, dbName, dbPassword, dbPort, dbUser, engine, kafkaBootstrapServers, leaderSelector, logger, producer

Constructor Summary

Constructors

Constructor and Description
EventTableChangesToAggregateTopicRelayPostgres(String kafkaBootstrapServers, String dbHost, int dbPort, String dbUser, String dbPassword, String dbName, org.apache.curator.framework.CuratorFramework client)

Method Summary

Modifier and Type	Method and Description
void	handleEvent(org.apache.kafka.connect.source.SourceRecord sourceRecord)
CompletableFuture<Object>	startCapturingChanges()

Methods inherited from class com.networknt.eventuate.debezium.EventTableChangesToAggregateTopicRelay

start, stop, stopCapturingChanges, toJson

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventTableChangesToAggregateTopicRelayPostgres

public EventTableChangesToAggregateTopicRelayPostgres(String kafkaBootstrapServers,
                                                      String dbHost,
                                                      int dbPort,
                                                      String dbUser,
                                                      String dbPassword,
                                                      String dbName,
                                                      org.apache.curator.framework.CuratorFramework client)

Method Detail

startCapturingChanges

public CompletableFuture<Object> startCapturingChanges()
                                                throws InterruptedException

Specified by:

startCapturingChanges in class EventTableChangesToAggregateTopicRelay

Throws:

InterruptedException

handleEvent

public void handleEvent(org.apache.kafka.connect.source.SourceRecord sourceRecord)

Specified by:

handleEvent in class EventTableChangesToAggregateTopicRelay