/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

2 votes260 views1 answer
Write custom query odoo
Python
2 votes135 views1 answer
Private variables python
Python
3 votes150 views1 answer
Python nmap
Python
5 votes154 views1 answer
Install pygaame using pip
Python
1 vote158 views1 answer
Set icon title tkinter
Python
28 votes141 views3 answers
Python import could not be resolved
Python
44 votes147 views5 answers
Python execute shell command
Python
0 vote170 views1 answer
Ssl django nginx
Python Django
0 vote150 views1 answer
Read all text file python
Python
10 votes176 views1 answer
Discord.py watching status
Python