summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDavid Arthur <mumrah@gmail.com>2012-10-02 12:30:04 -0400
committerDavid Arthur <mumrah@gmail.com>2012-10-02 12:30:04 -0400
commite5cf2500754ad458ba28383ce801f74439c631bb (patch)
tree19301b0abe3d7df4912006ae1c90002894180f5c
parent0844c0f46a74c9f409c802cc5c2a8ad8d106b4a4 (diff)
downloadkafka-python-e5cf2500754ad458ba28383ce801f74439c631bb.tar.gz
Fix tabs in README.md
-rw-r--r--README.md60
1 files changed, 30 insertions, 30 deletions
diff --git a/README.md b/README.md
index 787b6f3..52e80a2 100644
--- a/README.md
+++ b/README.md
@@ -66,10 +66,10 @@ python -m test.integration
## Send a message to a topic
```python
- from kafka.client import KafkaClient
- kafka = KafkaClient("localhost", 9092)
- kafka.send_messages_simple("my-topic", "some message")
- kafka.close()
+from kafka.client import KafkaClient
+kafka = KafkaClient("localhost", 9092)
+kafka.send_messages_simple("my-topic", "some message")
+kafka.close()
```
## Send several messages to a topic
@@ -77,9 +77,9 @@ python -m test.integration
Same as before, just add more arguments to `send\_simple`
```python
- kafka = KafkaClient("localhost", 9092)
- kafka.send_messages_simple("my-topic", "some message", "another message", "and another")
- kafka.close()
+kafka = KafkaClient("localhost", 9092)
+kafka.send_messages_simple("my-topic", "some message", "another message", "and another")
+kafka.close()
```
## Recieve some messages from a topic
@@ -87,10 +87,10 @@ Same as before, just add more arguments to `send\_simple`
Supply `get\_message\_set` with a `FetchRequest`, get back the messages and new `FetchRequest`
```python
- kafka = KafkaClient("localhost", 9092)
- req = FetchRequest("my-topic", 0, 0, 1024*1024)
- (messages, req1) = kafka.get_message_set(req)
- kafka.close()
+kafka = KafkaClient("localhost", 9092)
+req = FetchRequest("my-topic", 0, 0, 1024*1024)
+(messages, req1) = kafka.get_message_set(req)
+kafka.close()
```
The returned `FetchRequest` includes the offset of the next message. This makes
@@ -101,17 +101,17 @@ paging through the queue very simple.
For this we use the `send\_multi\_message\_set` method along with `ProduceRequest` objects.
```python
- kafka = KafkaClient("localhost", 9092)
- req1 = ProduceRequest("my-topic-1", 0, [
- create_message_from_string("message one"),
- create_message_from_string("message two")
- ])
- req2 = ProduceRequest("my-topic-2", 0, [
- create_message_from_string("nachricht ein"),
- create_message_from_string("nachricht zwei")
- ])
- kafka.sent_multi_message_set([req1, req1])
- kafka.close()
+kafka = KafkaClient("localhost", 9092)
+req1 = ProduceRequest("my-topic-1", 0, [
+ create_message_from_string("message one"),
+ create_message_from_string("message two")
+])
+req2 = ProduceRequest("my-topic-2", 0, [
+ create_message_from_string("nachricht ein"),
+ create_message_from_string("nachricht zwei")
+])
+kafka.sent_multi_message_set([req1, req1])
+kafka.close()
```
## Iterate through all messages from an offset
@@ -120,19 +120,19 @@ The `iter\_messages` method will make the underlying calls to `get\_message\_set
to provide a generator that returns every message available.
```python
- kafka = KafkaClient("localhost", 9092)
- for msg in kafka.iter_messages(FetchRequest("my-topic", 0, 0, 1024*1024)):
- print(msg.payload)
- kafka.close()
+kafka = KafkaClient("localhost", 9092)
+for msg in kafka.iter_messages(FetchRequest("my-topic", 0, 0, 1024*1024)):
+ print(msg.payload)
+kafka.close()
```
An optional `auto` argument will control auto-paging through results
```python
- kafka = KafkaClient("localhost", 9092)
- for msg in kafka.iter_messages(FetchRequest("my-topic", 0, 0, 1024*1024), False):
- print(msg.payload)
- kafka.close()
+kafka = KafkaClient("localhost", 9092)
+for msg in kafka.iter_messages(FetchRequest("my-topic", 0, 0, 1024*1024), False):
+ print(msg.payload)
+kafka.close()
```
This will only iterate through messages in the byte range of (0, 1024\*1024)