Consumer lag0 to 1000 thousand messages
Ingress rate0 to 100 thousand msg/s
Consume rate0 to 120 thousand msg/s
Rebalance risk0 to 1 probability
Broker utilization0 to 100 %
← All world models
a08/kafka-consumer-lag
Kafka Consumer Lag Recovery
Predict lag recovery and rank consumer, partition or producer interventions.
Prediction improvement97.03%
Planning top-1100%
Critical violations0
Runtime p950.13 ms
Training sourceA08 Kafka queue simulator v0.1
Training transitions3,200
Held-out one-step error0.20%
Held-out improvement96.90%
Interactive package
Change the context. Compare the plans.
The local runtime evaluates candidate control sequences, predicts their trajectories and rejects plans outside the declared envelope.
Live runtime
Plan from system state
Observed stateValues observed at H0
Planner search7 candidates · H6
Hold consumer groupScale consumersReassign partitionsTune fetchThrottle producersPause hot partition
Set the current telemetry, choose a goal and run the planner.
Results include actions, predicted state and constraint checks.World contract
One Kafka topic, bounded partition set and one consumer group during burst and member failure.
Temporal unit: 30_seconds. Supported horizons: 1, 4, 8.
Hold consumer grouphold group
Scale consumersscale consumers
Reassign partitionsreassign partitions
Tune fetchtune fetch
Throttle producersthrottle producers
Pause hot partitionpause hot partition
Clear consumer lag4 declared targets
broker saturationcritical · lte 96
rebalance instabilitycritical · lte 0.82
lag capacityhard · lte 950
Package record
Everything required to inspect and run this world.
Package digest
sha256:573ee250bade6d36208fa955ed27374c50ac238b5ed0707b1d4eef6902b8275eworld.jsonScope, lineage and runtime contract
model artifact285 parameter transition profile
schemas/State, action and goal validation
eval/40 registered cases and result digest
Declared limitationsSimulation-trained on one topic and consumer group with synthetic traffic.No transaction, schema, cross-cluster or disk-failure semantics.The package does not apply broker or consumer configuration.