Kafka Streams supports querying the state stores backing it various aggregation operators. However, there is no built in RPC framework, probably because everyone has their preferred one and maintaining multiple implementations would be a burden. This makes it hard for users to expose these stores, to other services or AI Agents, without writing a lot of boiler plate code.
We should investigate if we can create a library which will automate the exposure of these state stores and make it as easy as possible to expose them, securely, to other services and agents.
Kafka Streams supports querying the state stores backing it various aggregation operators. However, there is no built in RPC framework, probably because everyone has their preferred one and maintaining multiple implementations would be a burden. This makes it hard for users to expose these stores, to other services or AI Agents, without writing a lot of boiler plate code.
We should investigate if we can create a library which will automate the exposure of these state stores and make it as easy as possible to expose them, securely, to other services and agents.