THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
* ConsumerRecord<byte[], byte[]> create(final String topicName, final K key, final V value, final Headers headers, final long timestampMs)
* ConsumerRecord<byte[], byte[]> create(final String topicName, final K key, final V value, final Headers headers)
* ConsumerRecord<byte[], byte[]> create(final String topicName, final V value, final Headers headers, final long timestampMs)
* ConsumerRecord<byte[], byte[]> create(final String topicName, final V value, final Headers headers)
* ConsumerRecord<byte[], byte[]> create(final K key, final V value, final Headers headers, final long timestampMs)
* ConsumerRecord<byte[], byte[]> create(final K key, final V value, final Headers headers)
* ConsumerRecord<byte[], byte[]> create(final V value, final Headers headers, final long timestampMs)
* ConsumerRecord<byte[], byte[]> create(final V value, final Headers headers)
org.apache.kafka.streams.test.ConsumerRecordFactory:OutputVerifier
* void compareValueHeaders(final ProducerRecord<K, V> record, final V expectedValue, final Headers expectedHeaders)
* void compareValueHeaders(final ProducerRecord<K, V> record, final ProducerRecord<K, V> expectedRecord)
* void compareKeyValueHeaders(final ProducerRecord<K, V> record, final K expectedKey K, final V expectedValue, final Headers expectedHeaders)
* void compareKeyValueHeaders(final ProducerRecord<K, V> record, final ProducerRecord<K, V> expectedRecord)
* void compareKeyValueHeadersTimestamp(final ProducerRecord<K, V> record, final K expectedKey K, final V expectedValue, final Headers expectedHeaders, final long expectedTimestamp)
* void compareKeyValueHeadersTimestamp(final ProducerRecord<K, V> record, final ProducerRecord<K, V> expectedRecord)
...