THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
* void setHeaders(final Headers headers)
* Headers headers();
org.apache.kafka.streams.test.ConsumerRecordFactory: * 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)Proposed Changes
Adding `headers()` to `ProcessorContext` will enable custom processors and future DSL processors to have Headers available.
...