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 foo =
fooStore.get(fooKey); // foo != null

This returns a Foo which is not null.

FooKey has fields: [string(nullable), enum(nullable), string(nullable)]

I extended enum with a new value, say BAZ (I appended that at the end of
the enum) so it looks like:
"symbols": [
"A",
"B",
....,
"UNKNOWN"
"BAZ"
],
"default": "UNKNOWN"

and suddenly after this change,
for (FooKey fooKey : fooKeysRepository.get(Type.FOO)) { Foo foo =
fooStore.get(fooKey); // foo == null

I'm at a loss to understand why this is happening. There is no exception,
no trace in application logs, nothing.

What's more, the FooKey is always represented as {"string", null, "string"}
so the value for enum is consistently null.

Cheers,
Mariusz

Reply via email to