Package io.debezium.embedded

Class EmbeddedEngineTest

java.lang.Object

io.debezium.embedded.AbstractConnectorTest

io.debezium.embedded.EmbeddedEngineTest

All Implemented Interfaces:

Testing

public class EmbeddedEngineTest
extends AbstractConnectorTest

Author:

Randall Hauch

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	EmbeddedEngineTest.AddHeaderTransform
static class	EmbeddedEngineTest.FilterPredicate
static class	EmbeddedEngineTest.FilterTransform

Nested classes/interfaces inherited from class io.debezium.embedded.AbstractConnectorTest

AbstractConnectorTest.SourceRecords

Nested classes/interfaces inherited from interface io.debezium.util.Testing

Testing.Debug, Testing.Files, Testing.InterruptableFunction, Testing.Network, Testing.Print, Testing.Timer

Field Summary

Fields

Modifier and Type	Field	Description
private Configuration	connectorConfig
private File	inputFile
private int	linesAdded
private int	nextConsumedLineNumber
private static final int	NUMBER_OF_LINES
private static final Path	TEST_FILE_PATH
private static final Charset	UTF8

Fields inherited from class io.debezium.embedded.AbstractConnectorTest

consumedLines, engine, isEngineRunning, logger, logTestName, OFFSET_STORE_PATH, pollTimeoutInMs, requiresAssemblyProfileClassRule, requiresAssemblyProfileRule, skipTestRule

Constructor Summary

Constructors

Constructor	Description
EmbeddedEngineTest()

Method Summary

Modifier and Type	Method	Description
protected void	appendLinesToSource(int numberOfLines)
void	beforeEach()
protected void	consumeLines(int numberOfLines)
protected TestingDebeziumEngine<org.apache.kafka.connect.source.SourceRecord>	createEngine(io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord> builder)	Creates instance of DebeziumEngine which should be used for testing across the testsuite.
protected io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>	createEngineBuilder()	Creates instance of DebeziumEngine.Builder which corresponds to the DebeziumEngine provided by the AbstractConnectorTest.createEngine(DebeziumEngine.Builder) method.
void	interruptedOffsetCommitShutsDown()
void	interruptedTaskShutsDown()
void	invalidSmt()
void	shouldExecuteSmt()
void	shouldHandleNoDefaultOffsetFlushInterval()
void	shouldRunDebeziumEngine()
void	shouldRunDebeziumEngineWithJson()
void	shouldRunDebeziumEngineWithMismatchedTypes()
void	shouldRunDebeziumEngineWithString()
void	shouldRunEngineWithConsumerSettingOffsets()
void	shouldStartAndUseFileConnectorUsingMemoryOffsetStorage()
void	shouldWorkToUseCustomChangeConsumer()
void	validationThrowsException()
void	verifyBadCommitPolicyClassName()
void	verifyNonAsciiContentHandledCorrectly()

Methods inherited from class io.debezium.embedded.AbstractConnectorTest

assertBeginTransaction, assertConfigurationErrors, assertConfigurationErrors, assertConfigurationErrors, assertConnectorIsRunning, assertConnectorNotRunning, assertDelete, assertEndTransaction, assertEngineIsRunning, assertHasNoSourceQuery, assertInsert, assertKey, assertNoConfigurationErrors, assertNoRecordsToConsume, assertOffset, assertOffset, assertOnlyTransactionRecordsToConsume, assertRecordTransactionMetadata, assertSchemaMatchesStruct, assertSchemaMatchesStruct, assertSourceQuery, assertTombstone, assertTombstone, assertUpdate, assertValueField, cleanupTestFwkState, configValue, consumeAvailableRecords, consumeAvailableRecordsByTopic, consumeDmlRecordsByTopic, consumeDmlRecordsByTopic, consumeDmlRecordsByTopic, consumeRecord, consumeRecords, consumeRecords, consumeRecords, consumeRecordsButSkipUntil, consumeRecordsByTopic, consumeRecordsByTopic, consumeRecordsByTopic, consumeRecordsByTopicUntil, consumeRecordsUntil, debug, getConsumer, getMaximumEnqueuedRecordCount, getSnapshotMetricsObjectName, getSnapshotMetricsObjectName, getSnapshotMetricsObjectName, getSnapshotMetricsObjectName, getStreamingMetricsObjectName, getStreamingMetricsObjectName, getStreamingMetricsObjectName, getStreamingMetricsObjectName, getStreamingMetricsObjectName, getStreamingMetricsObjectName, getStreamingNamespace, initializeConnectorTestFramework, isStreamingRunning, isStreamingRunning, isStreamingRunning, isStreamingRunning, isTransactionRecord, loggingCompletion, print, readLastCommittedOffset, readLastCommittedOffsets, setConsumeTimeout, skipAvroValidation, start, start, start, start, start, start, start, startAndConsumeTillEnd, startAndConsumeTillEnd, stopConnector, stopConnector, storeOffsets, validate, waitForAvailableRecords, waitForAvailableRecords, waitForConnectorShutdown, waitForEngineShutdown, waitForSnapshotToBeCompleted, waitForSnapshotToBeCompleted, waitForSnapshotWithCustomMetricsToBeCompleted, waitForSnapshotWithCustomMetricsToBeCompleted, waitForStreamingRunning, waitForStreamingRunning, waitForStreamingRunning, waitForStreamingWithCustomMetricsToStart, waitForStreamingWithCustomMetricsToStart, waitTimeForEngine, waitTimeForRecords, waitTimeForRecordsAfterNulls

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.util.Testing

once, once, resetBeforeEachTest, time, time

Field Details

NUMBER_OF_LINES

private static final int NUMBER_OF_LINES

See Also:

• Constant Field Values

TEST_FILE_PATH

private static final Path TEST_FILE_PATH

UTF8

private static final Charset UTF8

inputFile

private File inputFile

nextConsumedLineNumber

private int nextConsumedLineNumber

linesAdded

private int linesAdded

connectorConfig

private Configuration connectorConfig

Constructor Details

EmbeddedEngineTest

public EmbeddedEngineTest()

Method Details

createEngineBuilder

protected io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord> createEngineBuilder()

Description copied from class: AbstractConnectorTest

Creates instance of DebeziumEngine.Builder which corresponds to the DebeziumEngine provided by the AbstractConnectorTest.createEngine(DebeziumEngine.Builder) method.

Specified by:

createEngineBuilder in class AbstractConnectorTest

createEngine

protected TestingDebeziumEngine<org.apache.kafka.connect.source.SourceRecord> createEngine(io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord> builder)

Description copied from class: AbstractConnectorTest

Creates instance of DebeziumEngine which should be used for testing across the testsuite.

Specified by:

createEngine in class AbstractConnectorTest

beforeEach

public void beforeEach()
                throws Exception

Throws:

Exception

verifyNonAsciiContentHandledCorrectly

public void verifyNonAsciiContentHandledCorrectly()
                                           throws Exception

Throws:

Exception

interruptedTaskShutsDown

public void interruptedTaskShutsDown()
                              throws Exception

Throws:

Exception

interruptedOffsetCommitShutsDown

public void interruptedOffsetCommitShutsDown()
                                      throws Exception

Throws:

Exception

shouldStartAndUseFileConnectorUsingMemoryOffsetStorage

public void shouldStartAndUseFileConnectorUsingMemoryOffsetStorage()
                                                            throws Exception

Throws:

Exception

shouldWorkToUseCustomChangeConsumer

@FixFor("DBZ-1080")
public void shouldWorkToUseCustomChangeConsumer()
                                         throws Exception

Throws:

Exception

shouldRunDebeziumEngine

public void shouldRunDebeziumEngine()
                             throws Exception

Throws:

Exception

shouldRunEngineWithConsumerSettingOffsets

@FixFor("DBZ-2897")
public void shouldRunEngineWithConsumerSettingOffsets()
                                               throws Exception

Throws:

Exception

shouldExecuteSmt

public void shouldExecuteSmt()
                      throws Exception

Throws:

Exception

invalidSmt

public void invalidSmt()
                throws Exception

Throws:

Exception

shouldRunDebeziumEngineWithJson

@FixFor("DBZ-1807")
public void shouldRunDebeziumEngineWithJson()
                                     throws Exception

Throws:

Exception

shouldRunDebeziumEngineWithString

public void shouldRunDebeziumEngineWithString()
                                       throws Exception

Throws:

Exception

shouldRunDebeziumEngineWithMismatchedTypes

@FixFor("DBZ-5926")
public void shouldRunDebeziumEngineWithMismatchedTypes()
                                                throws Exception

Throws:

Exception

verifyBadCommitPolicyClassName

@FixFor("DBZ-5583")
public void verifyBadCommitPolicyClassName()

validationThrowsException

@FixFor("DBZ-4720")
public void validationThrowsException()
                               throws Exception

Throws:

Exception

shouldHandleNoDefaultOffsetFlushInterval

@FixFor("DBZ-7099")
public void shouldHandleNoDefaultOffsetFlushInterval()
                                              throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

appendLinesToSource

protected void appendLinesToSource(int numberOfLines)
                            throws IOException

Throws:

IOException

consumeLines

protected void consumeLines(int numberOfLines)
                     throws InterruptedException

Throws:

InterruptedException