com.github.jcustenborder.kafka.connect.utils

Class AssertConnectRecord

java.lang.Object

com.github.jcustenborder.kafka.connect.utils.AssertConnectRecord

public class AssertConnectRecord
extends Object

Constructor Summary

Constructors

Constructor and Description
AssertConnectRecord()

Method Summary

Modifier and Type	Method and Description
static void	assertHeader(org.apache.kafka.connect.header.Header expected, org.apache.kafka.connect.header.Header actual)
static void	assertHeader(org.apache.kafka.connect.header.Header expected, org.apache.kafka.connect.header.Header actual, String message)
static void	assertHeaders(org.apache.kafka.connect.header.Headers expected, org.apache.kafka.connect.header.Headers actual)
static void	assertHeaders(org.apache.kafka.connect.header.Headers expected, org.apache.kafka.connect.header.Headers actual, String message)
static void	assertRecord(org.apache.kafka.connect.connector.ConnectRecord expected, org.apache.kafka.connect.connector.ConnectRecord actual)
static void	assertRecord(org.apache.kafka.connect.connector.ConnectRecord expected, org.apache.kafka.connect.connector.ConnectRecord actual, String message)
static void	assertSourceRecord(org.apache.kafka.connect.source.SourceRecord expected, org.apache.kafka.connect.source.SourceRecord actual)
static void	assertSourceRecord(org.apache.kafka.connect.source.SourceRecord expected, org.apache.kafka.connect.source.SourceRecord actual, String message)
static void	assertValue(Object expected, Object actual, String message)

Methods inherited from class java.lang.Object

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

Constructor Detail

AssertConnectRecord

public AssertConnectRecord()

Method Detail

assertValue

public static void assertValue(Object expected,
                               Object actual,
                               String message)

assertRecord

public static void assertRecord(org.apache.kafka.connect.connector.ConnectRecord expected,
                                org.apache.kafka.connect.connector.ConnectRecord actual)

assertRecord

public static void assertRecord(org.apache.kafka.connect.connector.ConnectRecord expected,
                                org.apache.kafka.connect.connector.ConnectRecord actual,
                                String message)

assertSourceRecord

public static void assertSourceRecord(org.apache.kafka.connect.source.SourceRecord expected,
                                      org.apache.kafka.connect.source.SourceRecord actual)

assertSourceRecord

public static void assertSourceRecord(org.apache.kafka.connect.source.SourceRecord expected,
                                      org.apache.kafka.connect.source.SourceRecord actual,
                                      String message)

assertHeader

public static void assertHeader(org.apache.kafka.connect.header.Header expected,
                                org.apache.kafka.connect.header.Header actual)

assertHeader

public static void assertHeader(org.apache.kafka.connect.header.Header expected,
                                org.apache.kafka.connect.header.Header actual,
                                String message)

assertHeaders

public static void assertHeaders(org.apache.kafka.connect.header.Headers expected,
                                 org.apache.kafka.connect.header.Headers actual)

assertHeaders

public static void assertHeaders(org.apache.kafka.connect.header.Headers expected,
                                 org.apache.kafka.connect.header.Headers actual,
                                 String message)