[KAFKA-10066] TopologyTestDriver isn't taking record headers into account during de/serialization

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.1.0
• Fix Version/s: 2.6.0, 2.5.1
• Component/s: streams-test-utils
• Assignee: Matthias J. Sax
• Reporter: Stefaan Dutry
• Created: 29/May/20 08:18
• Updated: 04/Jun/20 23:30
• Resolved: 04/Jun/20 23:30

Description

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: 

final K key = keyDeserializer.deserialize(record.topic(), record.key());
final V value = valueDeserializer.deserialize(record.topic(), record.value());

into: 

final K key = keyDeserializer.deserialize(record.topic(), record.headers(), record.key());
final V value = valueDeserializer.deserialize(record.topic(), record.headers(), record.value());

 

Issue Links

• links to: GitHub Pull Request #8759