Add support of Headers into TestRecord

LGouellec / kafka-streams-dotnet

.NET Stream Processing Library for Apache Kafka 🚀

https://lgouellec.github.io/kafka-streams-dotnet/

MIT License

455 stars 74 forks source link

Add support of Headers into TestRecord #150

Closed lollo25 closed 2 years ago

lollo25 commented 2 years ago

We need to make headers available within TestRecord class in order to test them using the provided TestTopologyDriver. Currently the value of Headers property of the record context within the test flow is always null because they are not implemented.

https://github.com/LGouellec/kafka-streams-dotnet/blob/c4018a03e5b64620542df9d88c4dace4ca6eb037/core/Mock/TestRecord.cs#L11

LGouellec commented 2 years ago

PR merged