- compareKeyValue(ProducerRecord<K, V>, K, V) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
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.
- compareKeyValue(ProducerRecord<K, V>, ProducerRecord<K, V>) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Compares the keys and values of two ProducerRecord
's and throws an AssertionError
if the keys or
values are not equal to each other.
- compareKeyValueTimestamp(ProducerRecord<K, V>, K, V, long) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
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.
- compareKeyValueTimestamp(ProducerRecord<K, V>, ProducerRecord<K, V>) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
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.
- compareValue(ProducerRecord<K, V>, V) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Compares a ProducerRecord
with the provided value and throws an AssertionError
if the
ProducerRecord
's value is not equal to the expected value.
- compareValue(ProducerRecord<K, V>, ProducerRecord<K, V>) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Compares the values of two ProducerRecord
's and throws an AssertionError
if they are not equal to
each other.
- compareValueTimestamp(ProducerRecord<K, V>, V, long) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
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.
- compareValueTimestamp(ProducerRecord<K, V>, ProducerRecord<K, V>) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Compares the values and timestamps of two ProducerRecord
's and throws an AssertionError
if the
values or timestamps are not equal to each other.
- ConsumerRecordFactory<K,V> - Class in org.apache.kafka.streams.test
-
Factory to create consumer records
for a single single-partitioned topic with given key and
value serializers
.
- ConsumerRecordFactory(Serializer<K>, Serializer<V>) - Constructor for class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Create a new factory for the given topic.
- ConsumerRecordFactory(String, Serializer<K>, Serializer<V>) - Constructor for class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Create a new factory for the given topic.
- ConsumerRecordFactory(Serializer<K>, Serializer<V>, long) - Constructor for class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Create a new factory for the given topic.
- ConsumerRecordFactory(String, Serializer<K>, Serializer<V>, long) - Constructor for class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Create a new factory for the given topic.
- ConsumerRecordFactory(Serializer<K>, Serializer<V>, long, long) - Constructor for class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Create a new factory for the given topic.
- ConsumerRecordFactory(String, Serializer<K>, Serializer<V>, long, long) - Constructor for class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Create a new factory for the given topic.
- create(String, K, V, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Create a ConsumerRecord
with the given topic name, key, value, and timestamp.
- create(K, V, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Create a ConsumerRecord
with default topic name and given key, value, and timestamp.
- create(String, K, V) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Create a ConsumerRecord
with the given topic name, key, and value.
- create(K, V) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Create a ConsumerRecord
with default topic name and given key and value.
- create(String, V, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Create a ConsumerRecord
with null
-key and the given topic name, value, and timestamp.
- create(V, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Create a ConsumerRecord
with default topic name and null
-key as well as given value and timestamp.
- create(String, V) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Create a ConsumerRecord
with null
-key and the given topic name and value.
- create(V) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Create a ConsumerRecord
with default topic name and null
-key was well as given value.
- create(String, List<KeyValue<K, V>>) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Creates consumer records
with the given topic name, keys, and values.
- create(List<KeyValue<K, V>>) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Creates consumer records
with default topic name as well as given keys and values.
- create(String, List<KeyValue<K, V>>, long, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Creates consumer records
with the given topic name, keys, and values.
- create(List<KeyValue<K, V>>, long, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Creates consumer records
with default topic name as well as given keys and values.
- create(String, List<KeyValue<K, V>>, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Creates consumer records
with the given topic name, keys and values.
- create(List<KeyValue<K, V>>, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Creates consumer records
with the given keys and values.