Package io.debezium.pipeline

Class EventDispatcher.StreamingChangeRecordReceiver

java.lang.Object

io.debezium.pipeline.EventDispatcher.StreamingChangeRecordReceiver

All Implemented Interfaces:

ChangeRecordEmitter.Receiver<P>

Enclosing class:

EventDispatcher<P extends Partition,T extends io.debezium.spi.schema.DataCollectionId>

private final class EventDispatcher.StreamingChangeRecordReceiver
extends Object
implements ChangeRecordEmitter.Receiver<P>

Constructor Summary

Constructors

Modifier	Constructor	Description
private	StreamingChangeRecordReceiver()

Method Summary

Modifier and Type	Method	Description
void	changeRecord(P partition, DataCollectionSchema dataCollectionSchema, Envelope.Operation operation, Object key, org.apache.kafka.connect.data.Struct value, OffsetContext offsetContext, org.apache.kafka.connect.header.ConnectHeaders headers)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.pipeline.spi.ChangeRecordEmitter.Receiver

unchangedEventSkipped

Constructor Details

StreamingChangeRecordReceiver

private StreamingChangeRecordReceiver()

Method Details

changeRecord

public void changeRecord(P partition,
 DataCollectionSchema dataCollectionSchema,
 Envelope.Operation operation,
 Object key,
 org.apache.kafka.connect.data.Struct value,
 OffsetContext offsetContext,
 org.apache.kafka.connect.header.ConnectHeaders headers)
                  throws InterruptedException

Specified by:

changeRecord in interface ChangeRecordEmitter.Receiver<P extends Partition>

Throws:

InterruptedException