Package io.debezium.embedded.async

Class AsyncEmbeddedEngineTest.CloseTestTransform

java.lang.Object

io.debezium.embedded.async.AsyncEmbeddedEngineTest.CloseTestTransform

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.source.SourceRecord>

Enclosing class:

AsyncEmbeddedEngineTest

public static class AsyncEmbeddedEngineTest.CloseTestTransform
extends Object
implements org.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.source.SourceRecord>

Field Summary

Fields

Modifier and Type	Field	Description
static boolean	wasClosed

Constructor Summary

Constructors

Constructor	Description
CloseTestTransform()

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.connect.source.SourceRecord	apply(org.apache.kafka.connect.source.SourceRecord record)
void	close()
org.apache.kafka.common.config.ConfigDef	config()
void	configure(Map<String,?> map)

Methods inherited from class java.lang.Object

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

Field Details

wasClosed

public static boolean wasClosed

Constructor Details

CloseTestTransform

public CloseTestTransform()

Method Details

apply

public org.apache.kafka.connect.source.SourceRecord apply(org.apache.kafka.connect.source.SourceRecord record)

Specified by:

apply in interface org.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.source.SourceRecord>

config

public org.apache.kafka.common.config.ConfigDef config()

Specified by:

config in interface org.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.source.SourceRecord>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.source.SourceRecord>

configure

public void configure(Map<String,?> map)

Specified by:

configure in interface org.apache.kafka.common.Configurable