Re: adding enum value in kafka streams

2023-09-20 Thread M M
.0:compile [INFO] | | \- org.apache.avro:avro-compiler:jar:1.10.0:compile Cheers, Mariusz On Wed, Sep 20, 2023 at 4:01 PM Bruno Cadonna wrote: > Hi Mariusz, > > How is fooKey de-/serialized? > > I ask that because maybe the serializer for fooKey cannot handle the > extended enum. > > Best, &g

adding enum value in kafka streams

2023-09-19 Thread M M
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