@@ -74,7 +74,7 @@ kafka.close()
74
74
75
75
## Send several messages to a topic
76
76
77
- Same as before, just add more arguments to ` send\_simple `
77
+ Same as before, just add more arguments to ` send_simple `
78
78
79
79
``` python
80
80
kafka = KafkaClient(" localhost" , 9092 )
@@ -84,7 +84,7 @@ kafka.close()
84
84
85
85
## Recieve some messages from a topic
86
86
87
- Supply ` get\_message\_set ` with a ` FetchRequest ` , get back the messages and new ` FetchRequest `
87
+ Supply ` get_message_set ` with a ` FetchRequest ` , get back the messages and new ` FetchRequest `
88
88
89
89
``` python
90
90
kafka = KafkaClient(" localhost" , 9092 )
@@ -98,7 +98,7 @@ paging through the queue very simple.
98
98
99
99
## Send multiple messages to multiple topics
100
100
101
- For this we use the ` send\_multi\_message\_set ` method along with ` ProduceRequest ` objects.
101
+ For this we use the ` send_multi_message_set ` method along with ` ProduceRequest ` objects.
102
102
103
103
``` python
104
104
kafka = KafkaClient(" localhost" , 9092 )
@@ -116,7 +116,7 @@ kafka.close()
116
116
117
117
## Iterate through all messages from an offset
118
118
119
- The ` iter\_messages ` method will make the underlying calls to ` get\_message\_set `
119
+ The ` iter_messages ` method will make the underlying calls to ` get_message_set `
120
120
to provide a generator that returns every message available.
121
121
122
122
``` python
0 commit comments