/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 vote121 views1 answer
How to set background color of an image to transparent in pygame
Python
21 votes118 views4 answers
Flask quickstart
Python
0 vote111 views1 answer
Python move cursor to previous line
Python
0 vote110 views1 answer
Minio python remove an object
Python
3 votes109 views1 answer
Spam python
Python
0 vote112 views1 answer
Python pprint on file
Python
1 vote116 views1 answer
Python async map
Python
0 vote121 views1 answer
Install easygui
Python
6 votes118 views3 answers
Python -m pip install
Python
86 votes120 views3 answers
How to read json from python
Python