Hi! Is there any documentation about how state management works? I want to modify the kafka source to manage the state at the connection level - instead of letting the kafka client manage it - but I can't find documentation about how state works in the Java CDK

A message from kapa.ai

Are there any Java examples?

hey luis, not anything official. You could look at the postgres source for inspiration on how it manages state

That's what I'm checking. As far as I understood, all is Json. I get the existing state as a json object when the source starts, and then I can update the json state using AirbyteSateMessages. If that's the case, I just need to define a record to represent the state and deal with the message emission in the read method