com.github.jcustenborder.kafka.connect.utils

Class AssertSchema

java.lang.Object

com.github.jcustenborder.kafka.connect.utils.AssertSchema

public class AssertSchema
extends Object

Method Summary

Modifier and Type	Method and Description
static void	assertField(org.apache.kafka.connect.data.Field expected, org.apache.kafka.connect.data.Field actual)
static void	assertField(org.apache.kafka.connect.data.Field expected, org.apache.kafka.connect.data.Field actual, String message)
static void	assertSchema(org.apache.kafka.connect.data.Schema expected, org.apache.kafka.connect.data.Schema actual)
static void	assertSchema(org.apache.kafka.connect.data.Schema expected, org.apache.kafka.connect.data.Schema actual, String message)

Methods inherited from class java.lang.Object

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

Method Detail

assertSchema

public static void assertSchema(org.apache.kafka.connect.data.Schema expected,
                                org.apache.kafka.connect.data.Schema actual)

assertSchema

public static void assertSchema(org.apache.kafka.connect.data.Schema expected,
                                org.apache.kafka.connect.data.Schema actual,
                                String message)

assertField

public static void assertField(org.apache.kafka.connect.data.Field expected,
                               org.apache.kafka.connect.data.Field actual,
                               String message)

assertField

public static void assertField(org.apache.kafka.connect.data.Field expected,
                               org.apache.kafka.connect.data.Field actual)