com.networknt.eventuate.debezium

Class EventTableChangesToAggregateTopicRelayMysql

java.lang.Object

com.networknt.eventuate.debezium.EventTableChangesToAggregateTopicRelay

com.networknt.eventuate.debezium.EventTableChangesToAggregateTopicRelayMysql

All Implemented Interfaces:

TableChangeToTopicRelay

public class EventTableChangesToAggregateTopicRelayMysql
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
EventTableChangesToAggregateTopicRelayMysql(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

EventTableChangesToAggregateTopicRelayMysql

public EventTableChangesToAggregateTopicRelayMysql(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