com.networknt.eventuate.debezium

Class EventTableChangesToAggregateTopicRelay

java.lang.Object

com.networknt.eventuate.debezium.EventTableChangesToAggregateTopicRelay

All Implemented Interfaces:

TableChangeToTopicRelay

Direct Known Subclasses:

EventTableChangesToAggregateTopicRelayMysql, EventTableChangesToAggregateTopicRelayPostgres

public abstract class EventTableChangesToAggregateTopicRelay
extends Object
implements TableChangeToTopicRelay

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

Field Summary

Fields

Modifier and Type	Field and Description
protected String	dbHost
protected String	dbName
protected String	dbPassword
protected int	dbPort
protected String	dbUser
protected io.debezium.embedded.EmbeddedEngine	engine
static String	kafkaBootstrapServers
protected org.apache.curator.framework.recipes.leader.LeaderSelector	leaderSelector
protected org.slf4j.Logger	logger
protected CdcKafkaProducer	producer

Constructor Summary

Constructors

Constructor and Description
EventTableChangesToAggregateTopicRelay(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
abstract void	handleEvent(org.apache.kafka.connect.source.SourceRecord sourceRecord)
void	start()
abstract CompletableFuture<Object>	startCapturingChanges()
void	stop()
void	stopCapturingChanges()
static String	toJson(PublishedEvent eventInfo)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected org.slf4j.Logger logger

producer

protected CdcKafkaProducer producer

engine

protected io.debezium.embedded.EmbeddedEngine engine

kafkaBootstrapServers

public static String kafkaBootstrapServers

dbHost

protected final String dbHost

dbPort

protected final int dbPort

dbUser

protected final String dbUser

dbPassword

protected final String dbPassword

dbName

protected final String dbName

leaderSelector

protected final org.apache.curator.framework.recipes.leader.LeaderSelector leaderSelector

Constructor Detail

EventTableChangesToAggregateTopicRelay

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

Method Detail

start

public void start()

Specified by:

start in interface TableChangeToTopicRelay

startCapturingChanges

public abstract CompletableFuture<Object> startCapturingChanges()
                                                         throws InterruptedException

Throws:

InterruptedException

stop

public void stop()
          throws InterruptedException

Specified by:

stop in interface TableChangeToTopicRelay

Throws:

InterruptedException

stopCapturingChanges

public void stopCapturingChanges()
                          throws InterruptedException

Throws:

InterruptedException

handleEvent

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

toJson

public static String toJson(PublishedEvent eventInfo)