Merge pull request #282 from wedaly/sphinx-api-docs

Add Sphinx API docs

1 files changed, 5 insertions, 0 deletions

diff --git a/kafka/context.py b/kafka/context.py
index 98ed7b3..ade4db8 100644
--- a/kafka/context.py
+++ b/kafka/context.py
@@ -18,6 +18,8 @@ class OffsetCommitContext(object):
 
     Example:
 
+    .. code:: python
+
         consumer = SimpleConsumer(client, group, topic, auto_commit=False)
         consumer.provide_partition_info()
         consumer.fetch_last_known_offsets()
@@ -57,7 +59,10 @@ class OffsetCommitContext(object):
         In order to know the current partition, it is helpful to initialize
         the consumer to provide partition info via:
 
+        .. code:: python
+
             consumer.provide_partition_info()
+
         """
         max_offset = max(offset + 1, self.high_water_mark.get(partition, 0))