Hey Bruno,
Thanks for your response.
Below you can find more details about serialization.
private SpecificAvroSerde fooKeySerde;
...
@PostConstruct
void postConstruct() {
this.fooKeySerde = configureSerde(true);
}
private SpecificAvroSerde configureSerde(boolean
isSerdeForRecordKeys) {
Hi Mariusz,
How is fooKey de-/serialized?
I ask that because maybe the serializer for fooKey cannot handle the
extended enum.
Best,
Bruno
On 9/20/23 12:22 AM, M M wrote:
Hello,
This is my first time asking a question on a mailing list, so please
forgive me any inaccuracies.
I am having a
Hello,
This is my first time asking a question on a mailing list, so please
forgive me any inaccuracies.
I am having a Kafka Streams application with a Punctuator.
Inside the punctuate() I have this code:
// fooStore is a state store
for (FooKey fooKey : fooKeysRepository.get(Type.FOO)) { Foo fo
