Is it possible to iterate over all the values in a GlobalKTable?
Not 100% sure what you mean in detail, but the answer should be “yes”.
Well my idea is a fan out. I would have event on topic A coming in and I want to process them for each value in the global ktable. There would only be about 3-5k thousand items in that table.
That is possible using the Processor API: instead of using a GlobalKTable, you use a “global store” (a GlobalKTable is just a wrapper around a global-store).
Any Processor can access the global store via the
context and you can do a
store#all() call for each input record.
StreamsBuilder#addGlobalStore() both allow you to add a global store.