[ https://issues.apache.org/jira/browse/KAFKA-10066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Matthias J. Sax reassigned KAFKA-10066: --------------------------------------- Assignee: Matthias J. Sax > TopologyTestDriver.createOutputTopic isn't taking record headers into account > during deserialization > ---------------------------------------------------------------------------------------------------- > > Key: KAFKA-10066 > URL: https://issues.apache.org/jira/browse/KAFKA-10066 > Project: Kafka > Issue Type: Bug > Components: streams-test-utils > Affects Versions: 2.5.0 > Reporter: Stefaan Dutry > Assignee: Matthias J. Sax > Priority: Minor > > When testing a Kafka stream we need the TopologyTestDriver.createOutputTopic > to take record headers into account. > Is it possible to use the record headers when deserialising when using the > TopologyTestDriver.createOutputTopic? > The only thing that needs to change is: > {code:java} > final K key = keyDeserializer.deserialize(record.topic(), record.key()); > final V value = valueDeserializer.deserialize(record.topic(), > record.value());{code} > into: > {code:java} > final K key = keyDeserializer.deserialize(record.topic(), record.headers(), > record.key()); > final V value = valueDeserializer.deserialize(record.topic(), > record.headers(), record.value());{code} > -- This message was sent by Atlassian Jira (v8.3.4#803005)