@@ -37,13 +37,10 @@ Python versions
37
37
## High level
38
38
39
39
``` python
40
- from kafka.client import KafkaClient
41
- from kafka.consumer import SimpleConsumer
42
- from kafka.producer import SimpleProducer, KeyedProducer
43
-
44
- kafka = KafkaClient(" localhost:9092" )
40
+ from kafka import KafkaClient, SimpleProducer, SimpleConsumer
45
41
46
42
# To send messages synchronously
43
+ kafka = KafkaClient(" localhost:9092" )
47
44
producer = SimpleProducer(kafka)
48
45
49
46
# Note that the application is responsible for encoding messages to type str
@@ -97,9 +94,7 @@ kafka.close()
97
94
98
95
## Keyed messages
99
96
``` python
100
- from kafka.client import KafkaClient
101
- from kafka.producer import KeyedProducer
102
- from kafka.partitioner import HashedPartitioner, RoundRobinPartitioner
97
+ from kafka import KafkaClient, KeyedProducer, HashedPartitioner, RoundRobinPartitioner
103
98
104
99
kafka = KafkaClient(" localhost:9092" )
105
100
@@ -113,8 +108,7 @@ producer = KeyedProducer(kafka, partitioner=RoundRobinPartitioner)
113
108
114
109
## Multiprocess consumer
115
110
``` python
116
- from kafka.client import KafkaClient
117
- from kafka.consumer import MultiProcessConsumer
111
+ from kafka import KafkaClient, MultiProcessConsumer
118
112
119
113
kafka = KafkaClient(" localhost:9092" )
120
114
@@ -135,10 +129,13 @@ for message in consumer.get_messages(count=5, block=True, timeout=4):
135
129
## Low level
136
130
137
131
``` python
138
- from kafka.client import KafkaClient
132
+ from kafka import KafkaClient
133
+ from kafka.protocol import KafkaProtocol, ProduceRequest
134
+
139
135
kafka = KafkaClient(" localhost:9092" )
136
+
140
137
req = ProduceRequest(topic = " my-topic" , partition = 1 ,
141
- messages = [KafkaProdocol .encode_message(" some message" )])
138
+ messages = [KafkaProtocol .encode_message(" some message" )])
142
139
resps = kafka.send_produce_request(payloads = [req], fail_on_error = True )
143
140
kafka.close()
144
141
0 commit comments