Just got my app to publish into Kafka running in the Confluent Docker container, then Pinot picked up the message, decoded via Confluent's schema registry; and indexed it to the real-time table that I previously created.

Used the web interface to see the data in the table; I don't have the system pulling from Pinot via the Java API yet.