My use-case is, I want to create a realtime table with upsert capabilities that consumes from a partitioned kafka topic.
As I understand it:
• The Pinot Server instances are responsible for consuming from the kafka partitions into local segments.
• The Pinot Controller instances contain a mapping of which servers contain certain segments.
• Once the segments are completed (whether by space or time requirements) they are uploaded to a distributed file system.