Package io.debezium.pipeline

Class AbstractMetricsTest<T extends org.apache.kafka.connect.source.SourceConnector>

java.lang.Object

io.debezium.embedded.AbstractConnectorTest

io.debezium.embedded.async.AbstractAsyncEngineConnectorTest

io.debezium.pipeline.AbstractMetricsTest<T>

All Implemented Interfaces:

Testing

public abstract class AbstractMetricsTest<T extends org.apache.kafka.connect.source.SourceConnector>
extends AbstractAsyncEngineConnectorTest

Nested Class Summary

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 inherited from class io.debezium.embedded.AbstractConnectorTest

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

Constructor Summary

Constructors

Constructor	Description
AbstractMetricsTest()

Method Summary

Modifier and Type	Method	Description
void	assertAdvancedMetrics(long expectedInsert)
protected void	assertSnapshotMetrics()
private void	assertSnapshotNotExecutedMetrics()
protected void	assertSnapshotWithCustomMetrics(Map<String,String> customMetricTags)
protected void	assertStreamingMetrics(boolean checkAdvancedMetrics, long expectedEvents)
protected void	assertStreamingWithCustomMetrics(Map<String,String> customMetricTags, long expectedEvents)
protected abstract Configuration.Builder	config()
protected abstract String	connector()
protected String	database()
protected abstract void	executeInsertStatements()
protected abstract long	expectedEvents()
protected abstract Class<T>	getConnectorClass()
protected ObjectName	getMultiplePartitionStreamingMetricsObjectName()
protected ObjectName	getMultiplePartitionStreamingMetricsObjectNameCustomTags(Map<String,String> customTags)
protected ObjectName	getSnapshotMetricsObjectName()
protected ObjectName	getStreamingMetricsObjectName()
private void	insertRecords()
private void	invokeOperation(ObjectName objectName, String operation)
protected abstract Configuration.Builder	noSnapshot(Configuration.Builder config)
protected abstract String	server()
protected abstract boolean	snapshotCompleted()
protected void	start()
protected void	start(Function<Configuration.Builder,Configuration.Builder> custConfig)
protected abstract String	tableName()
protected String	task()
void	testAdvancedStreamingMetrics()
void	testLifecycle()
void	testPauseAndResumeAdvancedStreamingMetrics()
void	testSnapshotAndStreamingMetrics()
void	testSnapshotAndStreamingWithCustomMetrics()
void	testSnapshotOnlyMetrics()
void	testStreamingOnlyMetrics()

Methods inherited from class io.debezium.embedded.async.AbstractAsyncEngineConnectorTest

createEngine, createEngineBuilder, getSignaler

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

Constructor Details

AbstractMetricsTest

public AbstractMetricsTest()

Method Details

getConnectorClass

protected abstract Class<T> getConnectorClass()

connector

protected abstract String connector()

server

protected abstract String server()

config

protected abstract Configuration.Builder config()

noSnapshot

protected abstract Configuration.Builder noSnapshot(Configuration.Builder config)

executeInsertStatements

protected abstract void executeInsertStatements()
                                         throws Exception

Throws:

Exception

tableName

protected abstract String tableName()

expectedEvents

protected abstract long expectedEvents()

snapshotCompleted

protected abstract boolean snapshotCompleted()

task

protected String task()

database

protected String database()

start

protected void start()

start

protected void start(Function<Configuration.Builder,Configuration.Builder> custConfig)

testLifecycle

public void testLifecycle()
                   throws Exception

Throws:

Exception

testSnapshotOnlyMetrics

public void testSnapshotOnlyMetrics()
                             throws Exception

Throws:

Exception

testSnapshotAndStreamingMetrics

public void testSnapshotAndStreamingMetrics()
                                     throws Exception

Throws:

Exception

testSnapshotAndStreamingWithCustomMetrics

@FixFor("DBZ-6603")
public void testSnapshotAndStreamingWithCustomMetrics()
                                               throws Exception

Throws:

Exception

testStreamingOnlyMetrics

public void testStreamingOnlyMetrics()
                              throws Exception

Throws:

Exception

testAdvancedStreamingMetrics

public void testAdvancedStreamingMetrics()
                                  throws Exception

Throws:

Exception

testPauseAndResumeAdvancedStreamingMetrics

public void testPauseAndResumeAdvancedStreamingMetrics()
                                                throws Exception

Throws:

Exception

insertRecords

private void insertRecords()
                    throws Exception

Throws:

Exception

assertSnapshotMetrics

protected void assertSnapshotMetrics()
                              throws Exception

Throws:

Exception

assertSnapshotWithCustomMetrics

protected void assertSnapshotWithCustomMetrics(Map<String,String> customMetricTags)
                                        throws Exception

Throws:

Exception

assertSnapshotNotExecutedMetrics

private void assertSnapshotNotExecutedMetrics()
                                       throws Exception

Throws:

Exception

assertStreamingMetrics

protected void assertStreamingMetrics(boolean checkAdvancedMetrics,
 long expectedEvents)
                               throws Exception

Throws:

Exception

assertAdvancedMetrics

public void assertAdvancedMetrics(long expectedInsert)
                           throws Exception

Throws:

Exception

invokeOperation

private void invokeOperation(ObjectName objectName,
 String operation)
                      throws ReflectionException,
InstanceNotFoundException,
MBeanException

Throws:

ReflectionException

InstanceNotFoundException

MBeanException

assertStreamingWithCustomMetrics

protected void assertStreamingWithCustomMetrics(Map<String,String> customMetricTags,
 long expectedEvents)
                                         throws Exception

Throws:

Exception

getSnapshotMetricsObjectName

protected ObjectName getSnapshotMetricsObjectName()
                                           throws MalformedObjectNameException

Throws:

MalformedObjectNameException

getStreamingMetricsObjectName

protected ObjectName getStreamingMetricsObjectName()
                                            throws MalformedObjectNameException

Throws:

MalformedObjectNameException

getMultiplePartitionStreamingMetricsObjectName

protected ObjectName getMultiplePartitionStreamingMetricsObjectName()
                                                             throws MalformedObjectNameException

Throws:

MalformedObjectNameException

getMultiplePartitionStreamingMetricsObjectNameCustomTags

protected ObjectName getMultiplePartitionStreamingMetricsObjectNameCustomTags(Map<String,String> customTags)
                                                                       throws MalformedObjectNameException

Throws:

MalformedObjectNameException