Is there a way to expose state store results via an API endpoint

[shashi812]

I have got a requirement to expose the results of a global table to outside world via an API endpoint. Does anyone have any idea how to do this?

[LGouellec]

Hi @shashi812,

Little example where the application build a Global Table and iterate the store directly from the KafkaStream instance :

var config = new StreamConfig<StringSerDes, StringSerDes>
            {
                ApplicationId = $"test-app",
                BootstrapServers = "localhost:9092"
            };
            
            var globalTable = builder.GlobalTable("topic", 
                RocksDb.As<string, string>("global-store"));
            
            var stream = new KafkaStream(builder.Build(), config);

            var globalStore = stream.Store(StoreQueryParameters.FromNameAndType(
                "global-store",
                QueryableStoreTypes.KeyValueStore<string, string>()));

            // get all the items from the store
            globalStore.All();

Best regards,