THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
package org.apache.kafka.streams.test; public class TestRecord<K, V> { //Constructors public TestRecord(final V value); public TestRecord(final K key, final V value); public TestRecord(final K key, final V value, final Headers headers); public TestRecord(Long timestamp,final K key, final V value, final Long timestamp); public TestRecord(Long timestamp,final K key, final V value, final Headers headers, final Long timestamp); //Constructor based on existing record public TestRecord(final ConsumerRecord<K, V> record); public TestRecord(final ProducerRecord<K, V> record); // Methods like in ProducerRecord / ConsumerRecord public Headers headers(); public K key(); public V value(); public Long timestamp(); // Getters public Headers getHeaders(); public K getKey(); public V getValue(); public Long getTimestamp(); //Overrides public String toString(); public boolean equals(Object o); public int hashCode(); } |
...