/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 vote188 views1 answer
Cv2.namedwindow
Python
1 vote222 views1 answer
How to add char to string python
Python
2 votes185 views2 answers
How to split a list to 1000 items python
Python
1 vote192 views1 answer
Add age categories pandas dataframe
Python
5 votes265 views6 answers
Python 3 cheat sheet
Python
71 votes205 views6 answers
Virtual env in python
Python
0 vote206 views1 answer
Django model manager user
Python
0 vote210 views1 answer
Pandas convert text duration to minutes
Python
0 vote226 views1 answer
Como calcular el rango en python
Python
2 votes185 views2 answers
Instance variable python
Python