anchor.diff:  }
   ----
   
  -This offset can even be moved forward (to skip records) and backwards (to replay records):
  +This offset can even be moved forward (to skip records) and backward (to replay records):
   
   [source,java]
   ----
       consumer.seekToBeginning(consumer.assignment());
   ----
   
  -== Using the Spring framework
  +== Using a framework
   
   You may have noticed that the consumer API is a pull API.
   In a real application you'll have to create a consuming loop in separate thread,
  
positive.code: ----
  <1> Connect to these Kafka connect nodes.
    Like the producer, it doesn't have to be the whole Kafka cluster.
  <2> Register this application as a consumer for this list of topics.
    Kafka will assign some partitions to this consumer.
  <3> Try to pull messages from the broker.
  <4> Pulled messages are automatically acknowledged.
  
  In the above example, connecting to the broker, subscribing to one or more topics,
  and being assigned partitions takes time and is usually done once during application start-up.
  On the contrary, the `poll` should be run in loop,
  it returns a batch of records whose size is controlled by the `max.poll.records` setting.
  
  Unlike the producer, the consumer is not thread-safe.
  In order to consumer records in parallel, each thread should have it's own consumer.
  
  == Acknowledging received messages
  
  The message acknowledgement is called offset commit,
  because Kafka keeps track the offset of the last consumed message for each topic + partition + consumer group.
  
  In the previous example, the offsets were automatically and periodically committed to the broker.
  
  [source,java]
  ----
  
negative.code: In the above example, the topic has five partitions.
  Partition 0 has two replicas: one on node 2, the other node 3.
  The replica on node 2 is the leader.
  You will notice the leader partitions are evenly distributed among this 3 node cluster.
  
  Each partition is an independent log of events.
  In this log, messages are *sorted* by their arrival order.
  