[kafka][doc][skip ci] Add docs on how to change offset.

makasim · makasim · commit 3c1fd491a90a · 2018-01-05T01:07:01.000+02:00
diff --git a/docs/transport/kafka.md b/docs/transport/kafka.md
@@ -8,6 +8,7 @@ The transport uses [Kafka](https://kafka.apache.org/) streaming platform as a MQ
 * [Send message to queue](#send-message-to-queue)
 * [Consume message](#consume-message)
 * [Serialize message](#serialize-message)
+* [Chnage offset](#change-offset)
 
 ## Installation
 
@@ -84,6 +85,9 @@ $fooQueue = $psrContext->createQueue('foo');
 
 $consumer = $psrContext->createConsumer($fooQueue);
 
+// Enable async commit to gain better performance. 
+//$consumer->setCommitAsync(true);
+
 $message = $consumer->receive();
 
 // process a message
@@ -115,4 +119,21 @@ class FooSerializer implements Serializer
 $psrContext->setSerializer(new FooSerializer());
 ```
 
+## Change offset
+
+By default consumers starts from the beginning of the topic and updates the offset while you are processing messages.
+There is an ability to change the current offset.
+
+```php
+<?php
+/** @var \Enqueue\RdKafka\RdKafkaContext $psrContext */
+
+$fooQueue = $psrContext->createQueue('foo');
+
+$consumer = $psrContext->createConsumer($fooQueue);
+$consumer->setOffset(123);
+
+$message = $consumer->receive(2000);
+```
+
 [back to index](index.md)
