Consumers

In plain English

Consumer groups share partitions and track offsets.

• One partition per consumer in a group.
• Commit offsets after processing.
• Rebalance when members change.

consumer.subscribe(List.of("lessons"));
while (true) {
  var records = consumer.poll(Duration.ofMillis(500));
  records.forEach(r -> process(r.value()));
}