/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

1 vote199 views1 answer
Logging in with selenium
Python
29 votes198 views5 answers
Python date and time
Python
-1 vote243 views1 answer
Set form field disabled django
Python Django
0 vote181 views1 answer
Tensorfow list devices
Python
19 votes209 views2 answers
How to check datatype of column in dataframe python
Python
15 votes275 views3 answers
Inverse matrix python
Python
-1 vote228 views2 answers
How to do date time formatting with strftime in python
Python
0 vote202 views1 answer
Positive counter python
Python
1 vote195 views2 answers
N factorial
Python
0 vote197 views2 answers
Django form formatting
Python