### online_stream_consumption

```{eval-rst}
.. plantuml::

   @startuml
   skinparam shadowing false
   title Online Path — Notebook Consumes from AlgoX2 (Kafka API)
   
   actor User
   participant "Tracto Notebook" as NB
   participant "AlgoX2 Gateway\n(Kafka API)" as GW
   participant "AlgoX2 Sequencer" as SQ
   participant "AlgoX2 Storage" as ST
   
   User -> NB : Start training / exploration
   NB -> GW : Kafka Consumer\n(SASL/TLS, group.id, EOS)
   GW -> SQ : fetch/assign, poll
   SQ -> ST : read sequential log
   ST --> SQ : records
   SQ --> GW : batch of records
   GW --> NB : messages (poll)
   
   NB -> NB : process → tensors, commit offsets
   NB -> GW : commit offsets (sync)
   
   User <- NB : results/plots
   @enduml