/Python/Kafka get last offset of topic python

Kafka get last offset of topic python

from kafka import SimpleClient
from kafka.protocol.offset import OffsetRequest, OffsetResetStrategy
from kafka.common import OffsetRequestPayload

client = SimpleClient(brokers)

partitions = client.topic_partitions[topic]
offset_requests = [OffsetRequestPayload(topic, p, -1, 1) for p in partitions.keys()]

offsets_responses = client.send_offset_request(offset_requests)

for r in offsets_responses:
    print "partition = %s, offset = %s"%(r.partition, r.offsets[0])

Source: stackoverflow.com

Similar codes

0 vote338 views1 answer
Add suffix to multiple file names python
Python
0 vote324 views2 answers
How to take input for list in one line in python
Python
0 vote335 views2 answers
Method get first last name python
Python
3 votes332 views1 answer
How set dely in python
Python
0 vote312 views1 answer
> not supported between tuple and int
Python
0 vote338 views1 answer
Automl time series forecasting
Python
0 vote306 views1 answer
Print 1to 10 number without using loop in python
Python
0 vote304 views1 answer
Python font
Python
3 votes343 views2 answers
Python find location of module
Python
0 vote324 views1 answer
Pyautogui color
Python