A C E G H K O T V
All Classes All Packages
All Classes All Packages
All Classes All Packages
A
- advanceTimeMs(long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Advances the internally tracked time.
C
- compareKeyValue(ProducerRecord<K, V>, K, V) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Deprecated.Compares a
ProducerRecord
with the provided key and value and throws anAssertionError
if theProducerRecord
'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
-
Deprecated.Compares the keys and values of two
ProducerRecord
's and throws anAssertionError
if the keys or values are not equal to each other. - compareKeyValueHeaders(ProducerRecord<K, V>, K, V, Headers) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Deprecated.Compares a
ProducerRecord
with the provided key, value, and headers and throws anAssertionError
if theProducerRecord
's key, value, or headers is not equal to the expected key, value, or headers. - compareKeyValueHeaders(ProducerRecord<K, V>, ProducerRecord<K, V>) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Deprecated.Compares the keys, values, and headers of two
ProducerRecord
's and throws anAssertionError
if the keys, values, or headers are not equal to each other. - compareKeyValueHeadersTimestamp(ProducerRecord<K, V>, K, V, Headers, long) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Deprecated.Compares a
ProducerRecord
with the provided key, value, headers, and timestamp and throws anAssertionError
if theProducerRecord
's key, value, headers, or timestamp is not equal to the expected key, value, headers, or timestamp. - compareKeyValueHeadersTimestamp(ProducerRecord<K, V>, ProducerRecord<K, V>) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Deprecated.Compares the keys, values, headers, and timestamp of two
ProducerRecord
's and throws anAssertionError
if the keys, values, headers, or timestamps are not equal to each other. - compareKeyValueTimestamp(ProducerRecord<K, V>, K, V, long) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Deprecated.Compares a
ProducerRecord
with the provided key, value, and timestamp and throws anAssertionError
if theProducerRecord
'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
-
Deprecated.Compares the keys, values, and timestamps of two
ProducerRecord
's and throws anAssertionError
if the keys, values, or timestamps are not equal to each other. - compareValue(ProducerRecord<K, V>, ProducerRecord<K, V>) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Deprecated.Compares the values of two
ProducerRecord
's and throws anAssertionError
if they are not equal to each other. - compareValue(ProducerRecord<K, V>, V) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Deprecated.Compares a
ProducerRecord
with the provided value and throws anAssertionError
if theProducerRecord
's value is not equal to the expected value. - compareValueHeaders(ProducerRecord<K, V>, ProducerRecord<K, V>) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Deprecated.Compares the values and headers of two
ProducerRecord
's and throws anAssertionError
if the values or headers are not equal to each other. - compareValueHeaders(ProducerRecord<K, V>, V, Headers) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Deprecated.Compares a
ProducerRecord
with the provided value and headers and throws anAssertionError
if theProducerRecord
's value or headers is not equal to the expected value or headers. - compareValueTimestamp(ProducerRecord<K, V>, ProducerRecord<K, V>) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Deprecated.Compares the values and timestamps of two
ProducerRecord
's and throws anAssertionError
if the values or timestamps are not equal to each other. - compareValueTimestamp(ProducerRecord<K, V>, V, long) - Static method in class org.apache.kafka.streams.test.OutputVerifier
-
Deprecated.Compares a
ProducerRecord
with the provided value and timestamp and throws anAssertionError
if theProducerRecord
's value or timestamp is not equal to the expected value or timestamp. - ConsumerRecordFactory<K,V> - Class in org.apache.kafka.streams.test
-
Deprecated.Since 2.4 use methods of
TestInputTopic
instead - ConsumerRecordFactory(String, Serializer<K>, Serializer<V>) - Constructor for class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a new factory for the given topic.
- ConsumerRecordFactory(String, Serializer<K>, Serializer<V>, long) - Constructor for class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.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
-
Deprecated.Create a new factory for the given topic.
- ConsumerRecordFactory(Serializer<K>, Serializer<V>) - Constructor for class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a new factory for the given topic.
- ConsumerRecordFactory(Serializer<K>, Serializer<V>, long) - Constructor for class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a new factory for the given topic.
- ConsumerRecordFactory(Serializer<K>, Serializer<V>, long, long) - Constructor for class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a new factory for the given topic.
- create(String, List<KeyValue<K, V>>) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Creates
consumer records
with the given topic name, keys, and values. - create(String, List<KeyValue<K, V>>, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Creates
consumer records
with the given topic name, keys and values. - create(String, List<KeyValue<K, V>>, long, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Creates
consumer records
with the given topic name, keys, and values. - create(String, K, V) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
with the given topic name, key, and value. - create(String, K, V, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
with the given topic name and given topic, key, value, and timestamp. - create(String, K, V, Headers) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
with the given topic name, key, value, and headers. - create(String, K, V, Headers, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
with the given topic name, key, value, headers, and timestamp. - create(String, V) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
withnull
-key and the given topic name and value. - create(String, V, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
withnull
-key and the given topic name, value, and timestamp. - create(String, V, Headers) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
withnull
-key and the given topic name, value, and headers. - create(String, V, Headers, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
withnull
-key and the given topic name, value, headers, and timestamp. - create(List<KeyValue<K, V>>) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Creates
consumer records
with default topic name as well as given keys and values. - create(List<KeyValue<K, V>>, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Creates
consumer records
with the given keys and values. - create(List<KeyValue<K, V>>, long, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Creates
consumer records
with default topic name as well as given keys and values. - create(K, V) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
with default topic name and given key and value. - create(K, V, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
with default topic name and given key, value, and timestamp. - create(K, V, Headers) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
with default topic name and given key, value, and headers. - create(K, V, Headers, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
with default topic name and given key, value, headers, and timestamp. - create(V) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
with default topic name andnull
-key was well as given value. - create(V, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
with default topic name andnull
-key as well as given value and timestamp. - create(V, Headers) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
with default topic name andnull
-key was well as given value and headers. - create(V, Headers, long) - Method in class org.apache.kafka.streams.test.ConsumerRecordFactory
-
Deprecated.Create a
ConsumerRecord
with default topic name andnull
-key as well as given value, headers, and timestamp.
E
- equals(Object) - Method in class org.apache.kafka.streams.test.TestRecord
G
- getHeaders() - Method in class org.apache.kafka.streams.test.TestRecord
- getKey() - Method in class org.apache.kafka.streams.test.TestRecord
- getRecordTime() - Method in class org.apache.kafka.streams.test.TestRecord
- getValue() - Method in class org.apache.kafka.streams.test.TestRecord
H
- hashCode() - Method in class org.apache.kafka.streams.test.TestRecord
- headers() - Method in class org.apache.kafka.streams.test.TestRecord
K
- key() - Method in class org.apache.kafka.streams.test.TestRecord
O
- org.apache.kafka.streams.test - package org.apache.kafka.streams.test
- OutputVerifier - Class in org.apache.kafka.streams.test
-
Deprecated.Since 2.4 use methods of
TestOutputTopic
and standard assertion libraries instead - OutputVerifier() - Constructor for class org.apache.kafka.streams.test.OutputVerifier
-
Deprecated.
T
- TestRecord<K,V> - Class in org.apache.kafka.streams.test
-
A key/value pair, including timestamp and record headers, to be sent to or received from
TopologyTestDriver
. - TestRecord(K, V) - Constructor for class org.apache.kafka.streams.test.TestRecord
-
Creates a record.
- TestRecord(K, V, Instant) - Constructor for class org.apache.kafka.streams.test.TestRecord
-
Creates a record.
- TestRecord(K, V, Headers) - Constructor for class org.apache.kafka.streams.test.TestRecord
-
Creates a record.
- TestRecord(K, V, Headers, Long) - Constructor for class org.apache.kafka.streams.test.TestRecord
-
Creates a record.
- TestRecord(K, V, Headers, Instant) - Constructor for class org.apache.kafka.streams.test.TestRecord
-
Creates a record.
- TestRecord(ConsumerRecord<K, V>) - Constructor for class org.apache.kafka.streams.test.TestRecord
-
Create a
TestRecord
from aConsumerRecord
. - TestRecord(ProducerRecord<K, V>) - Constructor for class org.apache.kafka.streams.test.TestRecord
-
Create a
TestRecord
from aProducerRecord
. - TestRecord(V) - Constructor for class org.apache.kafka.streams.test.TestRecord
-
Create a record with
null
key. - timestamp() - Method in class org.apache.kafka.streams.test.TestRecord
- toString() - Method in class org.apache.kafka.streams.test.TestRecord
V
- value() - Method in class org.apache.kafka.streams.test.TestRecord
All Classes All Packages