/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 vote231 views1 answer
Add header info in django response
Python Django
0 vote228 views1 answer
How to make game on python
Python
1 vote289 views1 answer
Django queryset multiple filters
Python Django
0 vote308 views1 answer
Python set day of date to 1
Python
3 votes185 views2 answers
How to install pygame in python 3.8
Python
0 vote182 views1 answer
"default_dburl" is not defined Pylance
Python
3 votes190 views2 answers
Secondary y axis matplotlib
Python
0 vote174 views1 answer
Pytorch get non diag element
Python
1 vote203 views1 answer
Yapf ignore line
Python
0 vote209 views1 answer
Limpiar consola en python
Python