The AbstractConnectorTest class provides several helper methods that other integration tests can use to ensure that all messages are valid. Currently validation just involves serialization and deserialization using Kafka Connect's built-in JSON converter, but it'd be great to also use Confluent's Avro converter.

See DBZ-63 for a recent change that added this dependency for use in unit tests.

Several of the naming conventions used in the Schema names is not compatible with the Avro naming conventions.