Kafka Connect integration test using TestContainers and a Custom SMT

Using TestContainers to integration test a Kafka Connect with a custom SMT.

See original StackOverflow question .

Setup

Ensure Java 11 JDK is installed / JAVA_HOME environment variable is set. To install e.g. OpenJDK, visit:

• OpenJDK Downloads - Java 11 JDK

Test

./gradlew test

This should produce something like the following:

> Task :test

smt.test.SmtIntegrationTest

  Test db_insert_creates_kakfa_message_with_smt() PASSED (2s)
  Test db_insert_creates_kakfa_message() PASSED (6s)

smt.test.RandomFieldTest

  Test topLevelStructRequired() PASSED
  Test schemalessInsertRandomField() PASSED
  Test copySchemaAndInsertUuidField() PASSED

SUCCESS: Executed 5 tests in 1m 20s