In Kafka 2.1, the `Serializer` and `Deserializer` interface were
changed:
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=87298242
It seems, that updating to 2.2.0 for the test driver does not update
your dependency to `kafka-client` package. Try to add this dependency
explicitly
It seems like the Kafka test driver is not compatible with the latest
kafka-streams API. When I use the following two dependencies together.
org.apache.kafka
kafka-streams-test-utils
2.2.0
test
org.apache.kafka
There is also `ValueTransformerWithKey` that gives you read-only acess
to the key.
-Matthias
On 4/12/19 5:34 PM, Alessandro Tagliapietra wrote:
> Hi Bruno,
>
> Thank you for the quick answer.
>
> I'm actually trying to do that since it seems there is really no way to
> have it use `Processor`.
