/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

4 votes99 views3 answers
Rgb color python
Python
12 votes104 views3 answers
Get screen size python
Python
1 vote96 views1 answer
Python how to make an empty list
Python
0 vote101 views1 answer
Python ip address is subnet of
Python
2 votes110 views1 answer
Python method to check for uppercase character
Python
4 votes82 views2 answers
Os.walk python
Python
0 vote122 views2 answers
How to convert c to python
Python
0 vote67 views1 answer
Pandas loop through unique values
Python
0 vote120 views1 answer
Copy model keras
Python
0 vote124 views4 answers
Python char to hex
Python