/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

9 votes148 views2 answers
Post request with proxy python
Python
7 votes106 views6 answers
Tensorflow version check
Python
4 votes106 views1 answer
Python turtle square
Python
0 vote115 views1 answer
Pip.exe The system cannot find the file specified
Python
0 vote143 views1 answer
Add x=y line to scatter plot python
Python
0 vote116 views1 answer
How to delete all instances of a model in django
Python
0 vote124 views1 answer
Is complex datatype immutable in python
Python
0 vote107 views1 answer
Ip address finder script python
Python
0 vote120 views1 answer
How to make curl request python
Python
0 vote125 views1 answer
Subtract different times in Python
Python