aio-libs / aio-libs/aiokafka

[QUESTION] How to get old messages from topics?

未關閉
#998 4 則留言 0 個 reaction 已指派 0 人 在 GitHub 檢視
question
主要語言
Python
星號
1.4k
分支
269
平均合併
1 天 1 小時
30 天內合併 PR
6

描述

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?

貢獻指南

開啟貢獻指南

評估

這個 Issue 還沒有評估資料。

把新 issue 寄到你的電子郵件信箱

精選適合新手參與的 GitHub issue 摘要。