org.apache.kafka.streams.test

Class OutputVerifier

java.lang.Object

org.apache.kafka.streams.test.OutputVerifier

public class OutputVerifier
extends Object

Helper class to verify topology result records.

See Also:

TopologyTestDriver

Constructor Summary

Constructors

Constructor and Description
OutputVerifier()

Method Summary

Modifier and Type	Method and Description
static <K,V> void	compareKeyValue(ProducerRecord<K,V> record, K expectedKey, V expectedValue) Compares a ProducerRecord with the provided key and value and throws an AssertionError if the ProducerRecord's key or value is not equal to the expected key or value.
static <K,V> void	compareKeyValue(ProducerRecord<K,V> record, ProducerRecord<K,V> expectedRecord) Compares the keys and values of two ProducerRecord's and throws an AssertionError if the keys or values are not equal to each other.
static <K,V> void	compareKeyValueHeaders(ProducerRecord<K,V> record, K expectedKey, V expectedValue, Headers expectedHeaders) Compares a ProducerRecord with the provided key, value, and headers and throws an AssertionError if the ProducerRecord's key, value, or headers is not equal to the expected key, value, or headers.
static <K,V> void	compareKeyValueHeaders(ProducerRecord<K,V> record, ProducerRecord<K,V> expectedRecord) Compares the keys, values, and headers of two ProducerRecord's and throws an AssertionError if the keys, values, or headers are not equal to each other.
static <K,V> void	compareKeyValueHeadersTimestamp(ProducerRecord<K,V> record, K expectedKey, V expectedValue, Headers expectedHeaders, long expectedTimestamp) Compares a ProducerRecord with the provided key, value, headers, and timestamp and throws an AssertionError if the ProducerRecord's key, value, headers, or timestamp is not equal to the expected key, value, headers, or timestamp.
static <K,V> void	compareKeyValueHeadersTimestamp(ProducerRecord<K,V> record, ProducerRecord<K,V> expectedRecord) Compares the keys, values, headers, and timestamp of two ProducerRecord's and throws an AssertionError if the keys, values, headers, or timestamps are not equal to each other.
static <K,V> void	compareKeyValueTimestamp(ProducerRecord<K,V> record, K expectedKey, V expectedValue, long expectedTimestamp) Compares a ProducerRecord with the provided key, value, and timestamp and throws an AssertionError if the ProducerRecord's key, value, or timestamp is not equal to the expected key, value, or timestamp.
static <K,V> void	compareKeyValueTimestamp(ProducerRecord<K,V> record, ProducerRecord<K,V> expectedRecord) Compares the keys, values, and timestamps of two ProducerRecord's and throws an AssertionError if the keys, values, or timestamps are not equal to each other.
static <K,V> void	compareValue(ProducerRecord<K,V> record, ProducerRecord<K,V> expectedRecord) Compares the values of two ProducerRecord's and throws an AssertionError if they are not equal to each other.
static <K,V> void	compareValue(ProducerRecord<K,V> record, V expectedValue) Compares a ProducerRecord with the provided value and throws an AssertionError if the ProducerRecord's value is not equal to the expected value.
static <K,V> void	compareValueHeaders(ProducerRecord<K,V> record, ProducerRecord<K,V> expectedRecord) Compares the values and headers of two ProducerRecord's and throws an AssertionError if the values or headers are not equal to each other.
static <K,V> void	compareValueHeaders(ProducerRecord<K,V> record, V expectedValue, Headers expectedHeaders) Compares a ProducerRecord with the provided value and headers and throws an AssertionError if the ProducerRecord's value or headers is not equal to the expected value or headers.
static <K,V> void	compareValueTimestamp(ProducerRecord<K,V> record, ProducerRecord<K,V> expectedRecord) Compares the values and timestamps of two ProducerRecord's and throws an AssertionError if the values or timestamps are not equal to each other.
static <K,V> void	compareValueTimestamp(ProducerRecord<K,V> record, V expectedValue, long expectedTimestamp) Compares a ProducerRecord with the provided value and timestamp and throws an AssertionError if the ProducerRecord's value or timestamp is not equal to the expected value or timestamp.

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputVerifier

public OutputVerifier()

Method Detail

compareValue

public static <K,V> void compareValue(ProducerRecord<K,V> record,
                                      V expectedValue)
                               throws AssertionError

Compares a ProducerRecord with the provided value and throws an AssertionError if the ProducerRecord's value is not equal to the expected value.

Type Parameters:

K - the key type

V - the value type

Parameters:

record - a output ProducerRecord for verification

expectedValue - the expected value of the ProducerRecord

Throws:

AssertionError - if ProducerRecord's value is not equal to expectedValue

compareValue

public static <K,V> void compareValue(ProducerRecord<K,V> record,
                                      ProducerRecord<K,V> expectedRecord)
                               throws AssertionError

Compares the values of two ProducerRecord's and throws an AssertionError if they are not equal to each other.

Type Parameters:

K - the key type

V - the value type

Parameters:

record - a output ProducerRecord for verification

expectedRecord - a ProducerRecord for verification

Throws:

AssertionError - if ProducerRecord's value is not equal to expectedRecord's value

compareKeyValue

public static <K,V> void compareKeyValue(ProducerRecord<K,V> record,
                                         K expectedKey,
                                         V expectedValue)
                                  throws AssertionError

Compares a ProducerRecord with the provided key and value and throws an AssertionError if the ProducerRecord's key or value is not equal to the expected key or value.

Type Parameters:

K - the key type

V - the value type

Parameters:

record - a output ProducerRecord for verification

expectedKey - the expected key of the ProducerRecord

expectedValue - the expected value of the ProducerRecord

Throws:

AssertionError - if ProducerRecord's key or value is not equal to expectedKey or expectedValue

compareKeyValue

public static <K,V> void compareKeyValue(ProducerRecord<K,V> record,
                                         ProducerRecord<K,V> expectedRecord)
                                  throws AssertionError

Compares the keys and values of two ProducerRecord's and throws an AssertionError if the keys or values are not equal to each other.

Type Parameters:

K - the key type

V - the value type

Parameters:

record - a output ProducerRecord for verification

expectedRecord - a ProducerRecord for verification

Throws:

AssertionError - if ProducerRecord's key or value is not equal to expectedRecord's key or value

compareValueTimestamp

public static <K,V> void compareValueTimestamp(ProducerRecord<K,V> record,
                                               V expectedValue,
                                               long expectedTimestamp)
                                        throws AssertionError

Compares a ProducerRecord with the provided value and timestamp and throws an AssertionError if the ProducerRecord's value or timestamp is not equal to the expected value or timestamp.

Type Parameters:

K - the key type

V - the value type

Parameters:

record - a output ProducerRecord for verification

expectedValue - the expected value of the ProducerRecord

expectedTimestamp - the expected timestamps of the ProducerRecord

Throws:

AssertionError - if ProducerRecord's value or timestamp is not equal to expectedValue or expectedTimestamp

compareValueTimestamp

public static <K,V> void compareValueTimestamp(ProducerRecord<K,V> record,
                                               ProducerRecord<K,V> expectedRecord)
                                        throws AssertionError

Compares the values and timestamps of two ProducerRecord's and throws an AssertionError if the values or timestamps are not equal to each other.

Type Parameters:

K - the key type

V - the value type

Parameters:

record - a output ProducerRecord for verification

expectedRecord - a ProducerRecord for verification

Throws:

AssertionError - if ProducerRecord's value or timestamp is not equal to expectedRecord's value or timestamp

compareKeyValueTimestamp

public static <K,V> void compareKeyValueTimestamp(ProducerRecord<K,V> record,
                                                  K expectedKey,
                                                  V expectedValue,
                                                  long expectedTimestamp)
                                           throws AssertionError

Compares a ProducerRecord with the provided key, value, and timestamp and throws an AssertionError if the ProducerRecord's key, value, or timestamp is not equal to the expected key, value, or timestamp.

Type Parameters:

K - the key type

V - the value type

Parameters:

record - a output ProducerRecord for verification

expectedKey - the expected key of the ProducerRecord

expectedValue - the expected value of the ProducerRecord

expectedTimestamp - the expected timestamp of the ProducerRecord

Throws:

AssertionError - if ProducerRecord's key, value, timestamp is not equal to expectedKey, expectedValue, or expectedTimestamps

compareKeyValueTimestamp

public static <K,V> void compareKeyValueTimestamp(ProducerRecord<K,V> record,
                                                  ProducerRecord<K,V> expectedRecord)
                                           throws AssertionError

Compares the keys, values, and timestamps of two ProducerRecord's and throws an AssertionError if the keys, values, or timestamps are not equal to each other.

Type Parameters:

K - the key type

V - the value type

Parameters:

record - a output ProducerRecord for verification

expectedRecord - a ProducerRecord for verification

Throws:

AssertionError - if ProducerRecord's key, value, or timestamp is not equal to expectedRecord's key, value, or timestamp

compareValueHeaders

public static <K,V> void compareValueHeaders(ProducerRecord<K,V> record,
                                             V expectedValue,
                                             Headers expectedHeaders)
                                      throws AssertionError

Compares a ProducerRecord with the provided value and headers and throws an AssertionError if the ProducerRecord's value or headers is not equal to the expected value or headers.

Type Parameters:

K - the key type

V - the value type

Parameters:

record - a output ProducerRecord for verification

expectedValue - the expected value of the ProducerRecord

expectedHeaders - the expected headers of the ProducerRecord

Throws:

AssertionError - if ProducerRecord's value or headers is not equal to expectedValue or expectedHeaders

compareValueHeaders

public static <K,V> void compareValueHeaders(ProducerRecord<K,V> record,
                                             ProducerRecord<K,V> expectedRecord)
                                      throws AssertionError

Compares the values and headers of two ProducerRecord's and throws an AssertionError if the values or headers are not equal to each other.

Type Parameters:

K - the key type

V - the value type

Parameters:

record - a output ProducerRecord for verification

expectedRecord - a ProducerRecord for verification

Throws:

AssertionError - if ProducerRecord's value or headers is not equal to expectedRecord's value or headers

compareKeyValueHeaders

public static <K,V> void compareKeyValueHeaders(ProducerRecord<K,V> record,
                                                K expectedKey,
                                                V expectedValue,
                                                Headers expectedHeaders)
                                         throws AssertionError

Compares a ProducerRecord with the provided key, value, and headers and throws an AssertionError if the ProducerRecord's key, value, or headers is not equal to the expected key, value, or headers.

Type Parameters:

K - the key type

V - the value type

Parameters:

record - a output ProducerRecord for verification

expectedKey - the expected key of the ProducerRecord

expectedValue - the expected value of the ProducerRecord

expectedHeaders - the expected headers of the ProducerRecord

Throws:

AssertionError - if ProducerRecord's key, value, headers is not equal to expectedKey, expectedValue, or expectedHeaders

compareKeyValueHeaders

public static <K,V> void compareKeyValueHeaders(ProducerRecord<K,V> record,
                                                ProducerRecord<K,V> expectedRecord)
                                         throws AssertionError

Compares the keys, values, and headers of two ProducerRecord's and throws an AssertionError if the keys, values, or headers are not equal to each other.

Type Parameters:

K - the key type

V - the value type

Parameters:

record - a output ProducerRecord for verification

expectedRecord - a ProducerRecord for verification

Throws:

AssertionError - if ProducerRecord's key, value, or headers is not equal to expectedRecord's key, value, or headers

compareKeyValueHeadersTimestamp

public static <K,V> void compareKeyValueHeadersTimestamp(ProducerRecord<K,V> record,
                                                         K expectedKey,
                                                         V expectedValue,
                                                         Headers expectedHeaders,
                                                         long expectedTimestamp)
                                                  throws AssertionError

Compares a ProducerRecord with the provided key, value, headers, and timestamp and throws an AssertionError if the ProducerRecord's key, value, headers, or timestamp is not equal to the expected key, value, headers, or timestamp.

Type Parameters:

K - the key type

V - the value type

Parameters:

record - a output ProducerRecord for verification

expectedKey - the expected key of the ProducerRecord

expectedValue - the expected value of the ProducerRecord

expectedHeaders - the expected headers of the ProducerRecord

expectedTimestamp - the expected timestamp of the ProducerRecord

Throws:

AssertionError - if ProducerRecord's key, value, headers is not equal to expectedKey, expectedValue, or expectedHeaders

compareKeyValueHeadersTimestamp

public static <K,V> void compareKeyValueHeadersTimestamp(ProducerRecord<K,V> record,
                                                         ProducerRecord<K,V> expectedRecord)
                                                  throws AssertionError

Compares the keys, values, headers, and timestamp of two ProducerRecord's and throws an AssertionError if the keys, values, headers, or timestamps are not equal to each other.

Type Parameters:

K - the key type

V - the value type

Parameters:

record - a output ProducerRecord for verification

expectedRecord - a ProducerRecord for verification

Throws:

AssertionError - if ProducerRecord's key, value, headers, or timestamp is not equal to expectedRecord's key, value, headers, or timestamp