/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 vote262 views1 answer
Sklearn kmeans mnist
Python
0 vote244 views2 answers
Python togli spazio
Python
8 votes236 views5 answers
Python print statements
Python
1 vote250 views1 answer
Url decode python
Python
1 vote245 views1 answer
How to write words on any other apps in python
Python
3 votes239 views2 answers
Python input lowercase
Python
2 votes260 views1 answer
Import validation error in django
Python Django
0 vote249 views1 answer
Python variables in multiline string
Python
1 vote262 views1 answer
_set in django
Python
2 votes220 views3 answers
Set axis ticks matplotlib
Python