I have a developer that wants to create a lookup table in Kafka with data that will be used later when sinking with S3. The lookup table will have folder information that will be used as a Bucket Assigner in the StreamingFileSink.
I thought using the Table API to generate the lookup table and build a collection for caching. Then query the cache with an ID that is being streamed. But it appears that you cannot mix APIs (Streaming, Table). Any ideas? thanks! -- Robert Cullen 240-475-4490
