Jørgen Ringen

In kafka-streams any leaked exception from user-code or any "permanent internal errors" causes the state to change to `Error -> Pending Shutdown -> Not Running`. We use this for our...

We use [kafka-streams in front](https://github.com/confluentinc/parallel-consumer#streams-usage) with avro, so it's not a practical issue for us as we control input topic. Our de-serde would also just log error and return null....

Btw, why isn't this a core feature in kafka-consumer? It seems like the only option is to create a "non-throwing" serde or create some sort of seek-logic. Or to use...

Okey, I see we should've avoided the cycle in the first place. Are there any preferable way of deferring the registration? As a first draft I'm doing a "lazy-lookup" from...

I thought about registering the MapStore in a BeanPostProcessor, but according to [com.hazelcast.config.Config](https://docs.hazelcast.org/docs/3.9/javadoc/com/hazelcast/config/Config.html) `[Config instances] should not be modified after they are used to create HazelcastInstance`. The creation of the...

Interesting. This error only occurs when the mapstore is added in the postconstruct. As far as I understand hazelcast does some kind of broadcasting of the config if the config...

We're experiencing this as well on 0.5.2.5. Sometimes happens on restarts where a partition is shuffled from one pod to another. Kafka client version 3.5.0. Don't know if it's the...