aio-libs / aio-libs/aiokafka

[QUESTION] How to get old messages from topics?

Open
#998 4 comments 0 reactions 0 assignees View on GitHub
question
Dominant language
Python
Stars
1.4k
Forks
269
Avg merge
1d 1h
Merged PRs (30d)
6

Description

Of course, I can get the messages with consumer in real time
```python
async def test():
consumer = AIOKafkaConsumer("test", bootstrap_servers="localhost:9092")
await consumer.start()
try:
async for message in consumer:
return message.value.decode()
finally:
await consumer.stop()
```
But what if I wanna get my old messages or find specific one from this topic?

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.